[jira] [Updated] (FLINK-18758) Support debezium data type in debezium format

2020-07-29 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu updated FLINK-18758: --- Description: Currently debezium json format  wrapper the json format to serialize/deserialize the d

[jira] [Commented] (FLINK-18755) RabbitMQ QoS Chinese Documentation

2020-07-29 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-18755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167678#comment-17167678 ] 吴彦祖 commented on FLINK-18755: - Hi,[~austince] I'm willing to translate this page. Would yo

[jira] [Commented] (FLINK-18760) Redundant task managers should be released when there's no job running in session cluster

2020-07-29 Thread Liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167666#comment-17167666 ] Liu commented on FLINK-18760: - Thanks for report this case, [~xintongsong]. I will fix it la

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167650#comment-17167650 ] Zhijiang edited comment on FLINK-18695 at 7/30/20, 5:59 AM:

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167650#comment-17167650 ] Zhijiang edited comment on FLINK-18695 at 7/30/20, 5:58 AM:

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167650#comment-17167650 ] Zhijiang edited comment on FLINK-18695 at 7/30/20, 5:58 AM:

[jira] [Comment Edited] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167650#comment-17167650 ] Zhijiang edited comment on FLINK-18695 at 7/30/20, 5:55 AM:

[jira] [Commented] (FLINK-18695) Allow NettyBufferPool to allocate heap buffers

2020-07-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167650#comment-17167650 ] Zhijiang commented on FLINK-18695: -- > Do we actually also cover the receiving side and

[jira] [Updated] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-07-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-18756: - Priority: Blocker (was: Major) > Support IF NOT EXISTS for CREATE TABLE statement > ---

[jira] [Closed] (FLINK-13872) Translate Operations Playground to Chinese

2020-07-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13872?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-13872. -- Fix Version/s: 1.12.0 Resolution: Fixed Thanks a lot for your contribution. Merged to

[jira] [Comment Edited] (FLINK-18758) Support debezium data type in debezium format

2020-07-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167646#comment-17167646 ] Jark Wu edited comment on FLINK-18758 at 7/30/20, 5:42 AM: --- Fo

[jira] [Commented] (FLINK-18758) Support debezium data type in debezium format

2020-07-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167646#comment-17167646 ] Jark Wu commented on FLINK-18758: - For this case, I think we can parse integer into date

[jira] [Closed] (FLINK-17886) Update Chinese documentation for new WatermarkGenerator/WatermarkStrategies

2020-07-29 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-17886. -- Resolution: Fixed Merged in https://github.com/apache/flink/commit/239372a5d085fa1ee075c368f3

[jira] [Commented] (FLINK-18760) Redundant task managers should be released when there's no job running in session cluster

2020-07-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18760?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167636#comment-17167636 ] Xintong Song commented on FLINK-18760: -- Offline discussed with [~Jiangang], and he'

[jira] [Created] (FLINK-18760) Redundant task managers should be released when there's no job running in session cluster

2020-07-29 Thread Xintong Song (Jira)
Xintong Song created FLINK-18760: Summary: Redundant task managers should be released when there's no job running in session cluster Key: FLINK-18760 URL: https://issues.apache.org/jira/browse/FLINK-18760

[jira] [Updated] (FLINK-18625) Maintain redundant taskmanagers to speed up failover

2020-07-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song updated FLINK-18625: - Fix Version/s: 1.12.0 > Maintain redundant taskmanagers to speed up failover > -

[jira] [Created] (FLINK-18759) Add readme.md for TPC-DS tools

2020-07-29 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18759: -- Summary: Add readme.md for TPC-DS tools Key: FLINK-18759 URL: https://issues.apache.org/jira/browse/FLINK-18759 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-18758) Support debezium data type in debezium format

2020-07-29 Thread Leonard Xu (Jira)
Leonard Xu created FLINK-18758: -- Summary: Support debezium data type in debezium format Key: FLINK-18758 URL: https://issues.apache.org/jira/browse/FLINK-18758 Project: Flink Issue Type: Improv

[jira] [Closed] (FLINK-18595) Deadlock during job shutdown

2020-07-29 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-18595. Resolution: Fixed Merged in master: c137102eb05e438bd97ec5e397ecb3d17342e6c1 Merged in release-1.11: aa688

[jira] [Commented] (FLINK-18508) Dynamic source supports statistics and parallelism report

2020-07-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167608#comment-17167608 ] Jark Wu commented on FLINK-18508: - Thank you for starting the discussion. I think {{@Int

[jira] [Created] (FLINK-18757) FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed with "Topic XX not present in metadata after 60000 ms"

2020-07-29 Thread Dian Fu (Jira)
Dian Fu created FLINK-18757: --- Summary: FlinkKafkaProducerITCase.testMigrateFromAtLeastOnceToExactlyOnce failed with "Topic XX not present in metadata after 6 ms" Key: FLINK-18757 URL: https://issues.apache.org/jira

[jira] [Commented] (FLINK-18508) Dynamic source supports statistics and parallelism report

2020-07-29 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167601#comment-17167601 ] Jingsong Lee commented on FLINK-18508: -- [~jark] Actually, they are internal APIs, a

[jira] [Commented] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-07-29 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167598#comment-17167598 ] Congxian Qiu(klion26) commented on FLINK-18748: --- Hi [~roman_khachatryan] t

[jira] [Updated] (FLINK-18748) Savepoint would be queued unexpected if pendingCheckpoints less than maxConcurrentCheckpoints

2020-07-29 Thread Congxian Qiu(klion26) (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Congxian Qiu(klion26) updated FLINK-18748: -- Summary: Savepoint would be queued unexpected if pendingCheckpoints less than

[jira] [Created] (FLINK-18756) Support IF NOT EXISTS for CREATE TABLE statement

2020-07-29 Thread Jark Wu (Jira)
Jark Wu created FLINK-18756: --- Summary: Support IF NOT EXISTS for CREATE TABLE statement Key: FLINK-18756 URL: https://issues.apache.org/jira/browse/FLINK-18756 Project: Flink Issue Type: New Featur

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

2020-07-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167595#comment-17167595 ] Dian Fu commented on FLINK-17274: - https://dev.azure.com/apache-flink/apache-flink/_buil

[jira] [Commented] (FLINK-18508) Dynamic source supports statistics and parallelism report

2020-07-29 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167594#comment-17167594 ] Jark Wu commented on FLINK-18508: - Should we have a public discussion for the public API

[jira] [Commented] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2020-07-29 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167590#comment-17167590 ] Xintong Song commented on FLINK-18681: -- [~Tao Yang], The containers are allocated

[jira] [Commented] (FLINK-18681) The jar package version conflict causes the task to continue to increase and grab resources

2020-07-29 Thread Tao Yang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167586#comment-17167586 ] Tao Yang commented on FLINK-18681: -- The WARN log ("Trying to release container not owne

[jira] [Updated] (FLINK-18755) RabbitMQ QoS Chinese Documentation

2020-07-29 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-18755: -- Description: Please add documentation for the new QoS settings in the RabbitMQ

[jira] [Updated] (FLINK-18755) RabbitMQ QoS Chinese Documentation

2020-07-29 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-18755: -- Issue Type: Improvement (was: Bug) > RabbitMQ QoS Chinese Documentation > ---

[jira] [Created] (FLINK-18755) RabbitMQ QoS Chinese Documentation

2020-07-29 Thread Austin Cawley-Edwards (Jira)
Austin Cawley-Edwards created FLINK-18755: - Summary: RabbitMQ QoS Chinese Documentation Key: FLINK-18755 URL: https://issues.apache.org/jira/browse/FLINK-18755 Project: Flink Issue Ty

[jira] [Issue Comment Deleted] (FLINK-17559) Backpressure seems to be broken when not going through network

2020-07-29 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Austin Cawley-Edwards updated FLINK-17559: -- Comment: was deleted (was: I think we can close this as well [~dwysakowicz], i

[jira] [Closed] (FLINK-17559) Backpressure seems to be broken when not going through network

2020-07-29 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17559. Resolution: Duplicate > Backpressure seems to be broken when not going through network > -

[jira] [Commented] (FLINK-17559) Backpressure seems to be broken when not going through network

2020-07-29 Thread Austin Cawley-Edwards (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17167462#comment-17167462 ] Austin Cawley-Edwards commented on FLINK-17559: --- I think we can close this

[jira] [Closed] (FLINK-6885) RMQSource does not support qos, leading to oom

2020-07-29 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-6885. --- Resolution: Duplicate > RMQSource does not support qos, leading to oom >

[jira] [Closed] (FLINK-10195) RabbitMQ Source With Checkpointing Doesn't Backpressure Correctly

2020-07-29 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-10195. Fix Version/s: 1.12.0 Resolution: Fixed Implemented in 3b6ca3c512f2742c84b3c623ac79

[jira] [Closed] (FLINK-17529) Upgrade com.rabbitmq:amqp-client to latest 5.x

2020-07-29 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-17529. Fix Version/s: 1.12.0 Assignee: Austin Cawley-Edwards Resolution: Fixed Im

[GitHub] [flink] flinkbot edited a comment on pull request #12791: [FLINK-18362][FLINK-13838][yarn] Add yarn.ship-archives to support LocalResourceType.ARCHIVE

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12791: URL: https://github.com/apache/flink/pull/12791#issuecomment-651128128 ## CI report: * 04378494874f6116cc118055a3e2c3359e75e6d9 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] dawidwys opened a new pull request #13021: [FLINK-12175] Change filling of typeHierarchy in analyzePojo, for correctly creating fields TypeInfo

2020-07-29 Thread GitBox
dawidwys opened a new pull request #13021: URL: https://github.com/apache/flink/pull/13021 This PR is a continuation of #8357 See the other PR for comments and description. This is an automated message from the Apache Git Se

[GitHub] [flink] flinkbot commented on pull request #13016: [FLINK-18508][table] Dynamic table supports statistics and parallelism report

2020-07-29 Thread GitBox
flinkbot commented on pull request #13016: URL: https://github.com/apache/flink/pull/13016#issuecomment-665550943 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12665: URL: https://github.com/apache/flink/pull/12665#issuecomment-644514775 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] dannycranmer commented on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-29 Thread GitBox
dannycranmer commented on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665529708 @xiaolong-sn I am using this branch for my EFO testing and in order to configure the connector I am doing this: - `consumerConfig.setProperty(EFO_CONSUMER_ARN_PREFIX + ".

[GitHub] [flink] yangyichao-mango commented on pull request #12665: [FLINK-17886][docs-zh] Update Chinese documentation for new Watermark…

2020-07-29 Thread GitBox
yangyichao-mango commented on pull request #12665: URL: https://github.com/apache/flink/pull/12665#issuecomment-665654578 Hi, Thx a lot for your review @klion26 , I have changed the `WatermarkStrategy` changes~ This is a

[GitHub] [flink] aljoscha commented on pull request #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

2020-07-29 Thread GitBox
aljoscha commented on pull request #7862: URL: https://github.com/apache/flink/pull/7862#issuecomment-665714396 There are some more comments on the Jira issue: https://issues.apache.org/jira/browse/FLINK-11779 This is an aut

[GitHub] [flink-docker] rmetzger closed pull request #31: [FLINK-16260] Change generate-stackbrew-library.sh to support new release.metadata file

2020-07-29 Thread GitBox
rmetzger closed pull request #31: URL: https://github.com/apache/flink-docker/pull/31 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] nielsbasjes commented on pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-29 Thread GitBox
nielsbasjes commented on pull request #12906: URL: https://github.com/apache/flink/pull/12906#issuecomment-665510162 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] aljoscha closed pull request #12906: [FLINK-18606][java-streaming] Remove unused generic parameter from SinkFunction.Context

2020-07-29 Thread GitBox
aljoscha closed pull request #12906: URL: https://github.com/apache/flink/pull/12906 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 #11896: [FLINK-14356] [single-value] Introduce "single-value" format to (de)serialize message to a single field

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #11896: URL: https://github.com/apache/flink/pull/11896#issuecomment-618808279 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot commented on pull request #13022: [hotfix][docs] Update currentInputNWatermark metrics docs including N-ary operator

2020-07-29 Thread GitBox
flinkbot commented on pull request #13022: URL: https://github.com/apache/flink/pull/13022#issuecomment-665684514 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13018: [FLINK-18709][Coordination] Implement PhysicalSlotProvider

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13018: URL: https://github.com/apache/flink/pull/13018#issuecomment-665565029 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #7862: URL: https://github.com/apache/flink/pull/7862#issuecomment-665725216 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[GitHub] [flink] dawidwys edited a comment on pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-07-29 Thread GitBox
dawidwys edited a comment on pull request #12729: URL: https://github.com/apache/flink/pull/12729#issuecomment-665737595 You can create a separate commit in this PR, where you do the bump and remove the `Delivery` class. You can tag this commit with FLINK-17529. --

[GitHub] [flink] xiaolong-sn commented on pull request #12920: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-29 Thread GitBox
xiaolong-sn commented on pull request #12920: URL: https://github.com/apache/flink/pull/12920#issuecomment-665518978 I lost my fork on the code so I reopen a new PR. This is an automated message from the Apache Git Service. T

[GitHub] [flink] Tartarus0zm commented on pull request #12931: [FLINK-18636][rest] Asynchronous close via configurable timeout in seconds for CompletedOperationCache

2020-07-29 Thread GitBox
Tartarus0zm commented on pull request #12931: URL: https://github.com/apache/flink/pull/12931#issuecomment-665596421 @tillrohrmann ok, closed This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] rkhachatryan edited a comment on pull request #12700: [FLINK-15467][task] Join source thread in SourceStreamTask.cancelTask

2020-07-29 Thread GitBox
rkhachatryan edited a comment on pull request #12700: URL: https://github.com/apache/flink/pull/12700#issuecomment-646487466 Joining the source thread in cancelTask won't work because cancelTask may be called from a different thread. Implemented a different approach in #12714 Closing

[GitHub] [flink] flinkbot edited a comment on pull request #12958: [FLINK-18625][runtime] Maintain redundant taskmanagers to speed up failover

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12958: URL: https://github.com/apache/flink/pull/12958#issuecomment-662378507 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] austince commented on a change in pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-07-29 Thread GitBox
austince commented on a change in pull request #12729: URL: https://github.com/apache/flink/pull/12729#discussion_r462315294 ## File path: flink-connectors/flink-connector-rabbitmq/src/main/resources/META-INF/NOTICE ## @@ -0,0 +1,9 @@ +flink-connector-rabbitmq +Copyright 2014-

[GitHub] [flink-docker] rmetzger commented on a change in pull request #32: [FLINK-16260] Add support for Java11 in dev-master / introduce new release.metadata file

2020-07-29 Thread GitBox
rmetzger commented on a change in pull request #32: URL: https://github.com/apache/flink-docker/pull/32#discussion_r462142561 ## File path: generator.sh ## @@ -0,0 +1,80 @@ +#!/bin/bash -e + +# Defaults, can vary between versions +export SOURCE_VARIANTS=(java11-debian debian )

[GitHub] [flink-web] sunjincheng121 commented on pull request #364: Add blog post for Pandas support in PyFlink.

2020-07-29 Thread GitBox
sunjincheng121 commented on pull request #364: URL: https://github.com/apache/flink-web/pull/364#issuecomment-665509485 Thanks for the nice comments @MarkSfik This is an automated message from the Apache Git Service. To

[GitHub] [flink] austince commented on pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-07-29 Thread GitBox
austince commented on pull request #12729: URL: https://github.com/apache/flink/pull/12729#issuecomment-665680169 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot commented on pull request #13017: [FLINK-18258][hive] Implement SHOW PARTITIONS for Hive dialect

2020-07-29 Thread GitBox
flinkbot commented on pull request #13017: URL: https://github.com/apache/flink/pull/13017#issuecomment-665558765 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] Thesharing commented on a change in pull request #12917: [WIP] [FLINK-18355][tests] Simplify tests of SlotPoolImpl

2020-07-29 Thread GitBox
Thesharing commented on a change in pull request #12917: URL: https://github.com/apache/flink/pull/12917#discussion_r462017275 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolBuilder.java ## @@ -35,9 +36,10 @@ */ public class Sl

[GitHub] [flink] SteNicholas opened a new pull request #13017: [FLINK-18258][hive] Implement SHOW PARTITIONS for Hive dialect

2020-07-29 Thread GitBox
SteNicholas opened a new pull request #13017: URL: https://github.com/apache/flink/pull/13017 ## What is the purpose of the change *Currently Hive dialect supports `ADD PARTITION` and `DROP PARTITION`, lack of support for `SHOW PARTITIONS`. It's necessary to implement `SHOW PARTITION

[GitHub] [flink] flinkbot commented on pull request #13021: [FLINK-12175] Change filling of typeHierarchy in analyzePojo, for correctly creating fields TypeInfo

2020-07-29 Thread GitBox
flinkbot commented on pull request #13021: URL: https://github.com/apache/flink/pull/13021#issuecomment-665644625 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665526783 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13022: [hotfix][docs] Update currentInputNWatermark metrics docs including N-ary operator

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13022: URL: https://github.com/apache/flink/pull/13022#issuecomment-665695875 ## CI report: * 84bfbfd4ea68572e3e41d1a7893d2e0fdd0d1dc6 Azure: [PENDING](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] xiaolong-sn opened a new pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-29 Thread GitBox
xiaolong-sn opened a new pull request #13015: URL: https://github.com/apache/flink/pull/13015 ## Note This is a redo of the closed PR(https://github.com/apache/flink/pull/12920). ## What is the purpose of the change *This is the fifth milestone of [FLIP-128](https://cwiki.a

[GitHub] [flink] flinkbot commented on pull request #13020: [FLINK-18663][rest] Fix the exception occurred on AbstractHandler#handleException but not handled

2020-07-29 Thread GitBox
flinkbot commented on pull request #13020: URL: https://github.com/apache/flink/pull/13020#issuecomment-665601454 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13021: [FLINK-12175] Change filling of typeHierarchy in analyzePojo, for correctly creating fields TypeInfo

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13021: URL: https://github.com/apache/flink/pull/13021#issuecomment-665655353 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #13011: [FLINK-16384][table sql/client] Support SHOW CREATE TABLE statement

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13011: URL: https://github.com/apache/flink/pull/13011#issuecomment-665419965 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] xiaolong-sn edited a comment on pull request #12920: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-29 Thread GitBox
xiaolong-sn edited a comment on pull request #12920: URL: https://github.com/apache/flink/pull/12920#issuecomment-665518978 I lost my fork on the code so I reopen a new PR. https://github.com/apache/flink/pull/13015 This i

[GitHub] [flink] flinkbot edited a comment on pull request #13014: [FLINK-18493][Deployment / YARN]Make target home directory used to store yarn files configurable

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13014: URL: https://github.com/apache/flink/pull/13014#issuecomment-665482028 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[jira] [Updated] (FLINK-18508) Dynamic source supports statistics and parallelism report

2020-07-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18508: --- Labels: pull-request-available (was: ) > Dynamic source supports statistics and parallelism

[GitHub] [flink] pnowojski opened a new pull request #13022: [hotfix][docs] Update currentInputNWatermark metrics docs including N-ary operator

2020-07-29 Thread GitBox
pnowojski opened a new pull request #13022: URL: https://github.com/apache/flink/pull/13022 This is a simple documentation update. ## Documentation - Does this pull request introduce a new feature? (yes / **no**) - If yes, how is the feature documented? (not applicable /

[GitHub] [flink] flinkbot edited a comment on pull request #12908: [FLINK-18449][table sql/api]Kafka topic discovery & partition discove…

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12908: URL: https://github.com/apache/flink/pull/12908#issuecomment-658771971 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink-docker] rmetzger commented on pull request #32: [FLINK-16260] Add support for Java11 in dev-master / introduce new release.metadata file

2020-07-29 Thread GitBox
rmetzger commented on pull request #32: URL: https://github.com/apache/flink-docker/pull/32#issuecomment-665612329 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

[GitHub] [flink] flinkbot edited a comment on pull request #9648: [FLINK-13872] [docs-zh] Translate Operations Playground to Chinese

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #9648: URL: https://github.com/apache/flink/pull/9648#issuecomment-529346361 ## CI report: * 63ee6304cd8415d6cd4d6d0e972680df3d39c4db Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?

[GitHub] [flink] pnowojski commented on a change in pull request #13000: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke

2020-07-29 Thread GitBox
pnowojski commented on a change in pull request #13000: URL: https://github.com/apache/flink/pull/13000#discussion_r462289373 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -562,6 +567,7 @@ private void runMailbo

[GitHub] [flink] flinkbot commented on pull request #7862: [FLINK-11779] CLI ignores -m parameter if high-availability is ZOOKEEPER

2020-07-29 Thread GitBox
flinkbot commented on pull request #7862: URL: https://github.com/apache/flink/pull/7862#issuecomment-665725216 ## CI report: * 7e69be8a6539b9f14ff01eab80e1d1f3f72e4052 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink-docker] rmetzger commented on pull request #31: [FLINK-16260] Change generate-stackbrew-library.sh to support new release.metadata file

2020-07-29 Thread GitBox
rmetzger commented on pull request #31: URL: https://github.com/apache/flink-docker/pull/31#issuecomment-665672761 Thank you for your thorough review! Merging ... This is an automated message from the Apache Git Servi

[GitHub] [flink] flinkbot edited a comment on pull request #12881: [FLINK-18512][kinesis] Introducing RecordPublisher. Refactor ShardConsumer to use PollingRecordPublisher

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12881: URL: https://github.com/apache/flink/pull/12881#issuecomment-657437295 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink-web] rmetzger commented on pull request #363: [blog] Flink Community Update - July'20

2020-07-29 Thread GitBox
rmetzger commented on pull request #363: URL: https://github.com/apache/flink-web/pull/363#issuecomment-665506485 Thank you for the update. Merging ... This is an automated message from the Apache Git Service. To respond to t

[GitHub] [flink] KevinZwx commented on pull request #13014: [FLINK-18493][Deployment / YARN]Make target home directory used to store yarn files configurable

2020-07-29 Thread GitBox
KevinZwx commented on pull request #13014: URL: https://github.com/apache/flink/pull/13014#issuecomment-665610532 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] flinkbot commented on pull request #13015: [FLINK-18536][kinesis] Adding enhanced fan-out related configurations.

2020-07-29 Thread GitBox
flinkbot commented on pull request #13015: URL: https://github.com/apache/flink/pull/13015#issuecomment-665519652 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] dawidwys commented on pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-07-29 Thread GitBox
dawidwys commented on pull request #12729: URL: https://github.com/apache/flink/pull/12729#issuecomment-665660452 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

[GitHub] [flink] flinkbot edited a comment on pull request #13007: [FLINK-15803][table] Update AggregateFunction and TableAggregateFunction to the new type system

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13007: URL: https://github.com/apache/flink/pull/13007#issuecomment-665020280 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] flinkbot edited a comment on pull request #12995: [FLINK-18517][k8s][release-1.10] Bump fabric8 version from 4.5.2 to 4.9.2

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12995: URL: https://github.com/apache/flink/pull/12995#issuecomment-664243022 ## CI report: * 855f9ec792d52b4a6426bba0f3ba1d3916b6d592 UNKNOWN * 9f28a149b48c7b97e5f60602f82fd92ac373d09e UNKNOWN * f64b730a1bd92e420264e6f9a8013c6d9e9b

[jira] [Updated] (FLINK-18700) Debezium-json format throws Exception when PG table's IDENTITY config is not FULL

2020-07-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18700: --- Labels: pull-request-available (was: ) > Debezium-json format throws Exception when PG tabl

[jira] [Updated] (FLINK-18258) Implement SHOW PARTITIONS for Hive dialect

2020-07-29 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-18258: --- Labels: pull-request-available (was: ) > Implement SHOW PARTITIONS for Hive dialect > -

[GitHub] [flink] flinkbot edited a comment on pull request #13013: [FLINK-18595][network] Fix the deadlock of concurrently recycling buffer and releasing input channel

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13013: URL: https://github.com/apache/flink/pull/13013#issuecomment-665451189 ## CI report: * 244a29783a58a8127a36a1add64d591cc077c76d Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] tillrohrmann commented on a change in pull request #13014: [FLINK-18493][Deployment / YARN]Make target home directory used to store yarn files configurable

2020-07-29 Thread GitBox
tillrohrmann commented on a change in pull request #13014: URL: https://github.com/apache/flink/pull/13014#discussion_r462277888 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterDescriptor.java ## @@ -1054,6 +1054,16 @@ private ApplicationReport startApp

[GitHub] [flink] flinkbot edited a comment on pull request #13017: [FLINK-18258][hive] Implement SHOW PARTITIONS for Hive dialect

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #13017: URL: https://github.com/apache/flink/pull/13017#issuecomment-665564915 This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

[GitHub] [flink] rkhachatryan commented on a change in pull request #13000: [FLINK-15467][task] Wait for sourceTaskThread to finish before exiting from StreamTask.invoke

2020-07-29 Thread GitBox
rkhachatryan commented on a change in pull request #13000: URL: https://github.com/apache/flink/pull/13000#discussion_r462304537 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java ## @@ -562,6 +567,7 @@ private void runMai

[GitHub] [flink] Tartarus0zm closed pull request #12931: [FLINK-18636][rest] Asynchronous close via configurable timeout in seconds for CompletedOperationCache

2020-07-29 Thread GitBox
Tartarus0zm closed pull request #12931: URL: https://github.com/apache/flink/pull/12931 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

[GitHub] [flink] Tartarus0zm commented on pull request #13020: [FLINK-18663][rest] Fix the exception occurred on AbstractHandler#handleException but not handled

2020-07-29 Thread GitBox
Tartarus0zm commented on pull request #13020: URL: https://github.com/apache/flink/pull/13020#issuecomment-665601262 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub

[GitHub] [flink] flinkbot edited a comment on pull request #12994: [FLINK-18728][network] Make initialCredit of RemoteInputChannel final

2020-07-29 Thread GitBox
flinkbot edited a comment on pull request #12994: URL: https://github.com/apache/flink/pull/12994#issuecomment-664206728 ## CI report: * 2efaa69c5791a59239feec7c122ba4fd39462238 Azure: [SUCCESS](https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/result

[GitHub] [flink] zentol commented on a change in pull request #13020: [FLINK-18663][rest] Fix the exception occurred on AbstractHandler#handleException but not handled

2020-07-29 Thread GitBox
zentol commented on a change in pull request #13020: URL: https://github.com/apache/flink/pull/13020#discussion_r462404713 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/AbstractHandler.java ## @@ -114,6 +115,21 @@ protected void respondAsLeade

[GitHub] [flink] austince edited a comment on pull request #12729: [FLINK-10195][connectors/rabbitmq] Allow setting QoS

2020-07-29 Thread GitBox
austince edited a comment on pull request #12729: URL: https://github.com/apache/flink/pull/12729#issuecomment-665735267 > What about the version bump? Do you want to do it as part of this PR? Yeah, sorry to miss that note, I'm good to do that as well! Should I tag the FLINK-17529 ti

[GitHub] [flink-docker] rmetzger edited a comment on pull request #32: [FLINK-16260] Add support for Java11 in dev-master / introduce new release.metadata file

2020-07-29 Thread GitBox
rmetzger edited a comment on pull request #32: URL: https://github.com/apache/flink-docker/pull/32#issuecomment-665671138 Note to self: There's one problem with this state: ``` Tags: 1.11.0-scala_2.11-java8, 1.11-scala_2.11-java8, scala_2.11-java8 Architectures: amd64 GitCommit:

  1   2   3   4   >