[GitHub] [flink] zentol commented on a change in pull request #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance

zentol commented on a change in pull request #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance URL: https://github.com/apache/flink/pull/8887#discussion_r314325761 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/De

[GitHub] [flink] zentol commented on a change in pull request #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance

zentol commented on a change in pull request #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance URL: https://github.com/apache/flink/pull/8887#discussion_r314324918 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/De

[GitHub] [flink] zentol commented on a change in pull request #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance

zentol commented on a change in pull request #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance URL: https://github.com/apache/flink/pull/8887#discussion_r314327170 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/metrics/De

[GitHub] [flink] flinkbot edited a comment on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

flinkbot edited a comment on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#issuecomment-521630829 ## CI report: * a68ae4c218cbb02c7e2c3e1422ac89909d7e05bb : SUCCESS [Build](https://travis-ci.com/flink-

[GitHub] [flink] flinkbot commented on issue #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance

flinkbot commented on issue #8887: [FLINK-12982][metrics] improve DescriptiveStatisticsHistogramStatistics performance URL: https://github.com/apache/flink/pull/8887#issuecomment-521657595 ## CI report: * 28175b7e7ef2b8d6f63345310fe0e63946c0c0ca : PENDING [Build](https://travis-ci.c

[GitHub] [flink] flinkbot commented on issue #8884: [FLINK-12981][metrics] ignore NaNs in percentile implementation

flinkbot commented on issue #8884: [FLINK-12981][metrics] ignore NaNs in percentile implementation URL: https://github.com/apache/flink/pull/8884#issuecomment-521657483 ## CI report: * f1465ced02653829076b1e0b967d3637fcd6c0c7 : PENDING [Build](https://travis-ci.com/flink-ci/flink/bu

[GitHub] [flink] jinxing64 commented on issue #7293: [FLINK-11144][tests] Make Tests runnable on Java 9

jinxing64 commented on issue #7293: [FLINK-11144][tests] Make Tests runnable on Java 9 URL: https://github.com/apache/flink/pull/7293#issuecomment-521655974 With this change, I failed the building. Apache Maven 3.5.2 JDK 8 -

[jira] [Commented] (FLINK-11144) Make Tests runnable on Java 9

[ https://issues.apache.org/jira/browse/FLINK-11144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908117#comment-16908117 ] jin xing commented on FLINK-11144: -- With this change, I failed the building. Apache Mav

[GitHub] [flink] zentol commented on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible

zentol commented on issue #8877: [FLINK-12984][metrics] only call Histogram#getStatistics() once where possible URL: https://github.com/apache/flink/pull/8877#issuecomment-521653044 You wanna squash the move of the test into #8886? --

[GitHub] [flink] flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner

flinkbot edited a comment on issue #9433: [FLINK-13708] [table-planner-blink] transformations should be cleared after execution in blink planner URL: https://github.com/apache/flink/pull/9433#issuecomment-521131546 ## CI report: * 22d047614613c293a7aca416268449b3cabcad6a : FAILURE [

[GitHub] [flink] zentol commented on a change in pull request #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen

zentol commented on a change in pull request #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen URL: https://github.com/apache/flink/pull/8886#discussion_r314321366 ## File path: flink-runtime/src/main/java/org/apa

[GitHub] [flink] zentol commented on a change in pull request #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen

zentol commented on a change in pull request #8886: [FLINK-12987][metrics] fix DescriptiveStatisticsHistogram#getCount() not returning the number of elements seen URL: https://github.com/apache/flink/pull/8886#discussion_r314321366 ## File path: flink-runtime/src/main/java/org/apa

[GitHub] [flink] flinkbot edited a comment on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1

flinkbot edited a comment on issue #9444: [FLINK-13726][docs] build docs with jekyll 4.0.0.pre.beta1 URL: https://github.com/apache/flink/pull/9444#issuecomment-521437894 ## CI report: * 85cc2e40579b09eaead5e8378f1019c7a2233897 : CANCELED [Build](https://travis-ci.com/flink-ci/flink

[jira] [Commented] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908098#comment-16908098 ] TisonKun commented on FLINK-13716: -- [~kkl0u] I'd like to hear from you whether you will

[GitHub] [flink] flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

flinkbot edited a comment on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-519130955 ## CI report: * 5d8448c4813f5b362f98f898998f1278f062d807 : FAILURE [Buil

[jira] [Created] (FLINK-13737) flink-dist should add provided dependency on flink-examples-table

Dawid Wysakowicz created FLINK-13737: Summary: flink-dist should add provided dependency on flink-examples-table Key: FLINK-13737 URL: https://issues.apache.org/jira/browse/FLINK-13737 Project: Fl

[GitHub] [flink] NicoK edited a comment on issue #9442: [FLINK-13729][docs] update website generation dependencies

NicoK edited a comment on issue #9442: [FLINK-13729][docs] update website generation dependencies URL: https://github.com/apache/flink/pull/9442#issuecomment-521627158 What do you mean? How would I test this? https://cwiki.apache.org/confluence/display/FLINK/Managing+Flink+Documentation ?

[GitHub] [flink] AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-521637692 > You are removing the `ExecutorService` from the `MailboxExecutorImpl` implementation i

[GitHub] [flink] AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on issue #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#issuecomment-521636762 > Implementation wise, it looks like the main (task level) mailbox (`TaskMailboxImpl`) b

[GitHub] [flink] AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314300937 ## File path: flink-streaming-java/src/main/java/org/apache/fl

[GitHub] [flink] xuyang1706 commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

xuyang1706 commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#issuecomment-521635674 > > Do you have any benchmark or performance tests? it would be helpful for understa

[GitHub] [flink] AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314299848 ## File path: flink-streaming-java/src/main/java/org/apache/fl

[GitHub] [flink] AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

AHeise commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314298805 ## File path: flink-streaming-java/src/main/java/org/apache/fl

[jira] [Assigned] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-13716: -- Assignee: TisonKun > Remove Program-related chinese documentation > -

[GitHub] [flink] twalthr commented on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

twalthr commented on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#issuecomment-521631237 @JingsongLi I think the `Known shortcomings or limitations for new features` could be quite large. Most of it should be docum

[GitHub] [flink] flinkbot commented on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

flinkbot commented on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#issuecomment-521630829 ## CI report: * a68ae4c218cbb02c7e2c3e1422ac89909d7e05bb : PENDING [Build](https://travis-ci.com/flink-ci/flin

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314291085 ## File path: flink-streaming-java/src/main/java/org/apache/flink

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314286078 ## File path: flink-streaming-java/src/main/java/org/apache/flink

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314286250 ## File path: flink-streaming-java/src/main/java/org/apache/flink

[GitHub] [flink] flinkbot commented on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

flinkbot commented on issue #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454#issuecomment-521629310 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-13644) Translate "State Backends" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-13644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13644: --- Labels: pull-request-available (was: ) > Translate "State Backends" page into Chinese > ---

[GitHub] [flink] fr836961905 opened a new pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese

fr836961905 opened a new pull request #9454: [FLINK-13644][docs-zh] Translate "State Backends" page into Chinese URL: https://github.com/apache/flink/pull/9454 ## What is the purpose of the change Translate "State Backends" page into Chinese ## Brief change log Tran

[GitHub] [flink] tillrohrmann commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

tillrohrmann commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314289274 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Rele

[GitHub] [flink] NicoK edited a comment on issue #9442: [FLINK-13729][docs] update website generation dependencies

NicoK edited a comment on issue #9442: [FLINK-13729][docs] update website generation dependencies URL: https://github.com/apache/flink/pull/9442#issuecomment-521627158 What do you mean? How would I test this? I could let travis build it once to verify (doc building seems to be a cron ta

[GitHub] [flink] NicoK commented on issue #9442: [FLINK-13729][docs] update website generation dependencies

NicoK commented on issue #9442: [FLINK-13729][docs] update website generation dependencies URL: https://github.com/apache/flink/pull/9442#issuecomment-521627158 What do you mean? How would I test this? I could let travis build it once to verify (doc building seems to be a cron task now

[jira] [Commented] (FLINK-13143) Refactor CheckpointExceptionHandler relevant classes

[ https://issues.apache.org/jira/browse/FLINK-13143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908045#comment-16908045 ] vinoyang commented on FLINK-13143: -- [~till.rohrmann] What's your opinion about my lates

[jira] [Commented] (FLINK-13707) Make max parallelism configurable

[ https://issues.apache.org/jira/browse/FLINK-13707?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908043#comment-16908043 ] xuekang commented on FLINK-13707: - [~StephanEwen]  yes, we provide a realtime computing

[jira] [Assigned] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13733: Assignee: Jiangjie Qin > FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis >

[jira] [Commented] (FLINK-13025) Elasticsearch 7.x support

[ https://issues.apache.org/jira/browse/FLINK-13025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908042#comment-16908042 ] vinoyang commented on FLINK-13025: -- [~aljoscha] [~till.rohrmann] Hope you are not very

[GitHub] [flink] JingsongLi commented on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

JingsongLi commented on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#issuecomment-521622880 @twalthr Do we need add some to `Known shortcomings or limitations for new features` for flink-planner? Just like DataType

[GitHub] [flink] wuchong commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

wuchong commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314284850 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release N

[GitHub] [flink] wuchong commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

wuchong commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314283634 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release N

[jira] [Comment Edited] (FLINK-13651) Blink planner should parse char(n)/varchar(n)/decimal(p, s)/timestamp(p) inside a string to corresponding datatype

[ https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907971#comment-16907971 ] Zhenghua Gao edited comment on FLINK-13651 at 8/15/19 12:18 PM: --

[GitHub] [flink] wuchong commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

wuchong commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314282790 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release N

[GitHub] [flink] 1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops

1u0 commented on a change in pull request #9383: [FLINK-13248] [runtime] Adding processing of downstream messages in AsyncWaitOperator's wait loops URL: https://github.com/apache/flink/pull/9383#discussion_r314280325 ## File path: flink-streaming-java/src/main/java/org/apache/flink

[jira] [Commented] (FLINK-13694) Refactor Flink on YARN configuration with relavent overlay classes to make hadoop user name env configurable

[ https://issues.apache.org/jira/browse/FLINK-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908028#comment-16908028 ] vinoyang commented on FLINK-13694: -- [~till.rohrmann] Done. Although I want to make {{HA

[jira] [Commented] (FLINK-11242) The predicate `'o_c_id === Null(Types.STRING)` not work in TableAPI

[ https://issues.apache.org/jira/browse/FLINK-11242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908025#comment-16908025 ] Jark Wu commented on FLINK-11242: - I agree with [~fhueske], the three-value logic is a w

[jira] [Closed] (FLINK-11960) Verify builtin Blink Table API functions and operators are reasonable

[ https://issues.apache.org/jira/browse/FLINK-11960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11960. --- Resolution: Duplicate > Verify builtin Blink Table API functions and operators are reasonable >

[jira] [Closed] (FLINK-11842) Introduce FlinkLogicalMatch

[ https://issues.apache.org/jira/browse/FLINK-11842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11842. --- Resolution: Duplicate Implemented in FLINK-13082. The timeout feature can be discussed in the future. > In

[jira] [Updated] (FLINK-13694) Refactor Flink on YARN configuration with relavent overlay classes to make hadoop user name env configurable

[ https://issues.apache.org/jira/browse/FLINK-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13694: - Summary: Refactor Flink on YARN configuration with relavent overlay classes to make hadoop user name env

[jira] [Updated] (FLINK-13694) Refactor Flink on YARN configuration with relavent overlay classes

[ https://issues.apache.org/jira/browse/FLINK-13694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang updated FLINK-13694: - Description: Our platform needs to provide a centralized submitter. We need to provide a customized env

[GitHub] [flink] flinkbot edited a comment on issue #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation

flinkbot edited a comment on issue #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation URL: https://github.com/apache/flink/pull/9453#issuecomment-521608405 ## CI report: * 0abb6f070dff64468f7c1132aca207beda5829cb : CANCELED [Build](https://travis-ci.com/flink-ci

[jira] [Commented] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908009#comment-16908009 ] TisonKun commented on FLINK-13716: -- [~kkl0u] as [~Zentol] suggested we can make this JI

[jira] [Updated] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-13716: - Attachment: 0001-FLINK-13716-docs-Remove-Program-related-Chinese-docu.patch > Remove Program-related chi

[GitHub] [flink] TisonKun closed pull request #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation

TisonKun closed pull request #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation URL: https://github.com/apache/flink/pull/9453 This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] TisonKun commented on issue #9452: [FLINK-13714] Remove Program-related code.

TisonKun commented on issue #9452: [FLINK-13714] Remove Program-related code. URL: https://github.com/apache/flink/pull/9452#issuecomment-521613267 @zentol I think attach a patch on the JIRA and @kl0u merge it locally works? T

[GitHub] [flink] zentol commented on issue #9452: [FLINK-13714] Remove Program-related code.

zentol commented on issue #9452: [FLINK-13714] Remove Program-related code. URL: https://github.com/apache/flink/pull/9452#issuecomment-521611913 @TisonKun could you just prepare a branch with the commit and send it to @kl0u ? Let's handle this in one go if possible. --

[GitHub] [flink] flinkbot commented on issue #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation

flinkbot commented on issue #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation URL: https://github.com/apache/flink/pull/9453#issuecomment-521608405 ## CI report: * 0abb6f070dff64468f7c1132aca207beda5829cb : PENDING [Build](https://travis-ci.com/flink-ci/flink/b

[jira] [Commented] (FLINK-13510) Show fail attemp for subtask in timelime

[ https://issues.apache.org/jira/browse/FLINK-13510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16908000#comment-16908000 ] lining commented on FLINK-13510: Now in timeline page has vertex timeline and subtask ti

[GitHub] [flink] flinkbot edited a comment on issue #9452: [FLINK-13714] Remove Program-related code.

flinkbot edited a comment on issue #9452: [FLINK-13714] Remove Program-related code. URL: https://github.com/apache/flink/pull/9452#issuecomment-521588157 ## CI report: * 1e9a07e9ffa1d8ae02e8fa26e543d5be01eacfe3 : SUCCESS [Build](https://travis-ci.com/flink-ci/flink/builds/123348301

[GitHub] [flink] flinkbot commented on issue #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation

flinkbot commented on issue #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation URL: https://github.com/apache/flink/pull/9453#issuecomment-521606221 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review you

[jira] [Updated] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13716: --- Labels: pull-request-available (was: ) > Remove Program-related chinese documentation > ---

[GitHub] [flink] TisonKun opened a new pull request #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation

TisonKun opened a new pull request #9453: [FLINK-13716][docs] Remove Program-related Chinese documentation URL: https://github.com/apache/flink/pull/9453 # What is the purpose of the change This PR is part of the removal of the `Program` interface, as discussed in [FLIP-52](https://

[GitHub] [flink] godfreyhe commented on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

godfreyhe commented on issue #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#issuecomment-521602216 other limitations: 1. The Blink planner only support the brand new `Catalog` and does not support `ExternalCatalog` whic

[jira] [Commented] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907989#comment-16907989 ] TisonKun commented on FLINK-13716: -- [~kkl0u] Sure I would do the review now. I'm glad t

[GitHub] [flink] TisonKun commented on issue #9452: [FLINK-13714] Remove Program-related code.

TisonKun commented on issue #9452: [FLINK-13714] Remove Program-related code. URL: https://github.com/apache/flink/pull/9452#issuecomment-521602026 I'm glad to update the Chinese version of the docs. Follow the workflow I need a committer assign the JIRA to me but of course I would concurre

[jira] [Updated] (FLINK-13708) transformations should be cleared because a table environment could execute multiple job

[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13708: Fix Version/s: (was: 1.9.0) 1.9.1 > transformations should be cleared because a tab

[GitHub] [flink] zentol commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

zentol commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258#discussion_r314258329 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/or

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13534: --- Fix Version/s: (was: 1.9.0) 1.9.1 > Unable to query Hive table with decimal c

[jira] [Updated] (FLINK-13708) transformations should be cleared because a table environment could execute multiple job

[ https://issues.apache.org/jira/browse/FLINK-13708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13708: --- Priority: Critical (was: Major) > transformations should be cleared because a table environment cou

[GitHub] [flink] zentol commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

zentol commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258#discussion_r314256600 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/or

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252037 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[jira] [Created] (FLINK-13736) Support count window with blink planner in batch mode

Kurt Young created FLINK-13736: -- Summary: Support count window with blink planner in batch mode Key: FLINK-13736 URL: https://issues.apache.org/jira/browse/FLINK-13736 Project: Flink Issue Type:

[jira] [Updated] (FLINK-13735) Support session window with blink planner in batch mode

[ https://issues.apache.org/jira/browse/FLINK-13735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young updated FLINK-13735: --- Component/s: Table SQL / Runtime > Support session window with blink planner in batch mode > ---

[jira] [Created] (FLINK-13735) Support session window with blink planner in batch mode

Kurt Young created FLINK-13735: -- Summary: Support session window with blink planner in batch mode Key: FLINK-13735 URL: https://issues.apache.org/jira/browse/FLINK-13735 Project: Flink Issue Typ

[jira] [Closed] (FLINK-11631) TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-11631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu closed FLINK-11631. Resolution: Won't Do > TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on > Tr

[jira] [Commented] (FLINK-11631) TaskExecutorITCase#testJobReExecutionAfterTaskExecutorTermination unstable on Travis

[ https://issues.apache.org/jira/browse/FLINK-11631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907982#comment-16907982 ] Biao Liu commented on FLINK-11631: -- We decide to close this PR and wait for the solutio

[GitHub] [flink] ifndef-SleePy commented on issue #9147: [FLINK-11631][test] Harden TaskExecutorITCase

ifndef-SleePy commented on issue #9147: [FLINK-11631][test] Harden TaskExecutorITCase URL: https://github.com/apache/flink/pull/9147#issuecomment-521596092 Hi @tillrohrmann , thanks for reviewing! Just a simple discussion below. > ... it violates encapsulation of the MiniCluster.

[GitHub] [flink] ifndef-SleePy closed pull request #9147: [FLINK-11631][test] Harden TaskExecutorITCase

ifndef-SleePy closed pull request #9147: [FLINK-11631][test] Harden TaskExecutorITCase URL: https://github.com/apache/flink/pull/9147 This is an automated message from the Apache Git Service. To respond to the message, pleas

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252037 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252925 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252037 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252037 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252925 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] NicoK commented on a change in pull request #9439: [FLINK-13728][docs] fix wrong closing tag order in sidenav

NicoK commented on a change in pull request #9439: [FLINK-13728][docs] fix wrong closing tag order in sidenav URL: https://github.com/apache/flink/pull/9439#discussion_r314253099 ## File path: docs/_includes/sidenav.html ## @@ -88,7 +88,7 @@ {% else %} {% assig

[GitHub] [flink] flinkbot edited a comment on issue #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell

flinkbot edited a comment on issue #9233: [FLINK-13415][docs] Document how to use hive connector in scala shell URL: https://github.com/apache/flink/pull/9233#issuecomment-515340558 ## CI report: * c825e2b8c2b212b1c214218395d577d38b4d7406 : SUCCESS [Build](https://travis-ci.com/flin

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252677 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0

KurtYoung commented on a change in pull request #9438: [WIP] [FLINK-13712] [docs] Add release notes for Flink 1.9.0 URL: https://github.com/apache/flink/pull/9438#discussion_r314252037 ## File path: docs/release-notes/flink-1.9.md ## @@ -0,0 +1,175 @@ +--- +title: "Release

[GitHub] [flink] azagrebin commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

azagrebin commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258#discussion_r314248198 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/test/java

[jira] [Closed] (FLINK-13730) Cache and share the downloaded external distribution (e.g. Kafka) in E2E tests

[ https://issues.apache.org/jira/browse/FLINK-13730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13730. --- Resolution: Duplicate FLINK-11463 is designing a caching mechanism to cache the downloaded artifacts. > Ca

[GitHub] [flink] tillrohrmann commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application

tillrohrmann commented on a change in pull request #9336: [FLINK-13548][Deployment/YARN]Support priority of the Flink YARN application URL: https://github.com/apache/flink/pull/9336#discussion_r314246453 ## File path: flink-yarn/src/main/java/org/apache/flink/yarn/configuration/Yar

[jira] [Commented] (FLINK-13730) Cache and share the downloaded external distribution (e.g. Kafka) in E2E tests

[ https://issues.apache.org/jira/browse/FLINK-13730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907972#comment-16907972 ] Jark Wu commented on FLINK-13730: - Oh, I just saw the description of FLINK-11463. And I

[GitHub] [flink] azagrebin commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass()

azagrebin commented on a change in pull request #9258: [FLINK-13460][tests] Rework SerializedThrowableTest to not use Unsafe#defineClass() URL: https://github.com/apache/flink/pull/9258#discussion_r314246617 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java

[jira] [Commented] (FLINK-13651) Blink planner should parse char(n)/varchar(n)/decimal(p, s)/timestamp(p) inside a string to corresponding datatype

[ https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907971#comment-16907971 ] Zhenghua Gao commented on FLINK-13651: -- PlannerExpressionParserImpl of Blink planne

[GitHub] [flink] flinkbot commented on issue #9452: [FLINK-13714] Remove Program-related code.

flinkbot commented on issue #9452: [FLINK-13714] Remove Program-related code. URL: https://github.com/apache/flink/pull/9452#issuecomment-521588157 ## CI report: * 1e9a07e9ffa1d8ae02e8fa26e543d5be01eacfe3 : PENDING [Build](https://travis-ci.com/flink-ci/flink/builds/123348301) -

[GitHub] [flink] ifndef-SleePy commented on a change in pull request #9072: [FLINK-11630] Wait for the termination of all running Tasks when shutting down TaskExecutor

ifndef-SleePy commented on a change in pull request #9072: [FLINK-11630] Wait for the termination of all running Tasks when shutting down TaskExecutor URL: https://github.com/apache/flink/pull/9072#discussion_r314245975 ## File path: flink-runtime/src/main/java/org/apache/flink/run

[jira] [Updated] (FLINK-13651) Blink planner should parse char(n)/varchar(n)/decimal(p, s)/timestamp(p) inside a string to corresponding datatype

[ https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-13651: - Summary: Blink planner should parse char(n)/varchar(n)/decimal(p, s)/timestamp(p) inside a strin

[jira] [Commented] (FLINK-13716) Remove Program-related chinese documentation

[ https://issues.apache.org/jira/browse/FLINK-13716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907970#comment-16907970 ] Kostas Kloudas commented on FLINK-13716: The PR is here [https://github.com/apac

[jira] [Updated] (FLINK-13651) Blink planner should support parse char(n)/varchar(n)/decimal(p, s)/timestamp(p) inside a string to corresponding datatype

[ https://issues.apache.org/jira/browse/FLINK-13651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenghua Gao updated FLINK-13651: - Summary: Blink planner should support parse char(n)/varchar(n)/decimal(p, s)/timestamp(p) inside

[jira] [Commented] (FLINK-13563) TumblingGroupWindow should implement toString method

[ https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16907969#comment-16907969 ] Jark Wu commented on FLINK-13563: - OK. I checked the plan tests and this change only aff

<    1   2   3   4   >