[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271601279 ## File path: flink-core/src/main/java/org/apache/flink/core/io/InputSplitAssigner.jav

[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271601172 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Exec

[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271599639 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Exec

[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271599475 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Exec

[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271599544 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Exec

[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271598214 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Exec

[GitHub] [flink] Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource…

Ryantaocer commented on a change in pull request #6684: [FLINK-10205] Batch Job: InputSplit Fault tolerant for DataSource… URL: https://github.com/apache/flink/pull/6684#discussion_r271598097 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/Exec

[GitHub] [flink] JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime

JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime URL: https://github.com/apache/flink/pull/8086#discussion_r271595499 ## File path: flink-table/flink-table-runtime-blink/src/main/java/or

[GitHub] [flink] dawidwys commented on issue #8087: [FLINK-12029][table] Add column operations for TableApi

dawidwys commented on issue #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#issuecomment-479358608 Thank you for understanding! Will definitely look once it will be rebased on the merged changes. ---

[GitHub] [flink] hequn8128 edited a comment on issue #8087: [FLINK-12029][table] Add column operations for TableApi

hequn8128 edited a comment on issue #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#issuecomment-479356007 @sunjincheng121 Sounds good. I will rebase the PR once [FLINK-11884](https://github.com/apache/flink/pull/8062/files) is

[GitHub] [flink] hequn8128 commented on issue #8087: [FLINK-12029][table] Add column operations for TableApi

hequn8128 commented on issue #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#issuecomment-479356007 @sunjincheng121 Sounds good. I will rebase the PR once [FLINK-11884](https://github.com/apache/flink/pull/8062/files) is merged.

[GitHub] [flink] flinkbot commented on issue #8106: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called

flinkbot commented on issue #8106: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8106#issuecomment-479336247 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] an0 opened a new pull request #8106: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called

an0 opened a new pull request #8106: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8106 This is an automated message from the Apache Git Service. To respond to the messag

[GitHub] [flink] KurtYoung commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime

KurtYoung commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime URL: https://github.com/apache/flink/pull/8086#discussion_r271575050 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org

[GitHub] [flink] an0 closed pull request #8104: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called

an0 closed pull request #8104: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8104 This is an automated message from the Apache Git Service. To respond to the message, ple

[GitHub] [flink] flinkbot commented on issue #8105: [FLINK-11309][core] Make blocking result partitions consumable

flinkbot commented on issue #8105: [FLINK-11309][core] Make blocking result partitions consumable URL: https://github.com/apache/flink/pull/8105#issuecomment-479332135 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] eaglewatcherwb opened a new pull request #8105: [FLINK-11309][core] Make blocking result partitions consumable

eaglewatcherwb opened a new pull request #8105: [FLINK-11309][core] Make blocking result partitions consumable URL: https://github.com/apache/flink/pull/8105 multiple times to speed up batch recoveries Change-Id: Id304257d201a9ea2c0f650c027204aabe2b2e9b9 ## What is th

[GitHub] [flink] flinkbot commented on issue #8104: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called

flinkbot commented on issue #8104: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8104#issuecomment-479328213 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] an0 opened a new pull request #8104: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called

an0 opened a new pull request #8104: [FLINK-12092] [docs]Clarity when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8104 This is an automated message from the Apache Git Service. To respond to the messag

[jira] [Updated] (FLINK-12092) Doc of when `onTimer(...)` is called is inaccurate

[ https://issues.apache.org/jira/browse/FLINK-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12092: --- Labels: pull-request-available (was: ) > Doc of when `onTimer(...)` is called is inaccurate

[GitHub] [flink] an0 closed pull request #8103: [FLINK-12092] [Documentation]

an0 closed pull request #8103: [FLINK-12092] [Documentation] URL: https://github.com/apache/flink/pull/8103 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Updated] (FLINK-12092) Doc of when `onTimer(...)` is called is inaccurate

[ https://issues.apache.org/jira/browse/FLINK-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ling Wang updated FLINK-12092: -- Description: The doc says: {quote}When a timer's particular time is reached, the `onTimer(...)` method

[jira] [Created] (FLINK-12092) Doc of when `onTimer(...)` is called is inacc

Ling Wang created FLINK-12092: - Summary: Doc of when `onTimer(...)` is called is inacc Key: FLINK-12092 URL: https://issues.apache.org/jira/browse/FLINK-12092 Project: Flink Issue Type: Improveme

[jira] [Updated] (FLINK-12092) Doc of when `onTimer(...)` is called is inaccurate

[ https://issues.apache.org/jira/browse/FLINK-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ling Wang updated FLINK-12092: -- Priority: Minor (was: Major) > Doc of when `onTimer(...)` is called is inaccurate > -

[jira] [Updated] (FLINK-12092) Doc of when `onTimer(...)` is called is inaccurate

[ https://issues.apache.org/jira/browse/FLINK-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ling Wang updated FLINK-12092: -- Summary: Doc of when `onTimer(...)` is called is inaccurate (was: Doc of when `onTimer(...)` is calle

[jira] [Updated] (FLINK-12092) Doc of when `onTimer(...)` is called is inaccurate

[ https://issues.apache.org/jira/browse/FLINK-12092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ling Wang updated FLINK-12092: -- Component/s: Documentation > Doc of when `onTimer(...)` is called is inaccurate >

[GitHub] [flink] flinkbot commented on issue #8103: Improve the doc of when `onTimer(...)` is called

flinkbot commented on issue #8103: Improve the doc of when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8103#issuecomment-479323083 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] [flink] an0 opened a new pull request #8103: Improve the doc of when `onTimer(...)` is called

an0 opened a new pull request #8103: Improve the doc of when `onTimer(...)` is called URL: https://github.com/apache/flink/pull/8103 The current doc is not accurate. ## What is the purpose of the change *(For example: This pull request makes task deployment go through

[GitHub] [flink] eaglewatcherwb closed pull request #7537: [FLINK-11309][core] make SpillableSubpartition repeatably read to enable

eaglewatcherwb closed pull request #7537: [FLINK-11309][core] make SpillableSubpartition repeatably read to enable URL: https://github.com/apache/flink/pull/7537 This is an automated message from the Apache Git Service. To r

[GitHub] [flink] JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime

JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime URL: https://github.com/apache/flink/pull/8086#discussion_r271567786 ## File path: flink-table/flink-table-runtime-blink/src/main/java/or

[GitHub] [flink] JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime

JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime URL: https://github.com/apache/flink/pull/8086#discussion_r271568421 ## File path: flink-table/flink-table-runtime-blink/src/main/java/or

[GitHub] [flink] JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime

JingsongLi commented on a change in pull request #8086: [FLINK-12062][table-runtime-blink] Introduce bundle operator to streaming table runtime URL: https://github.com/apache/flink/pull/8086#discussion_r271566995 ## File path: flink-table/flink-table-runtime-blink/src/main/java/or

[jira] [Created] (FLINK-12091) Can Flink support the historyserver function like spark?

彭洋 created FLINK-12091: -- Summary: Can Flink support the historyserver function like spark? Key: FLINK-12091 URL: https://issues.apache.org/jira/browse/FLINK-12091 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12090) Can the log on the Apache Flink Dashboard be partitioned by day?

彭洋 created FLINK-12090: -- Summary: Can the log on the Apache Flink Dashboard be partitioned by day? Key: FLINK-12090 URL: https://issues.apache.org/jira/browse/FLINK-12090 Project: Flink Issue Type: Imp

[jira] [Assigned] (FLINK-6227) Introduce the DataConsumptionException for downstream task failure

[ https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang reassigned FLINK-6227: --- Assignee: zhijiang > Introduce the DataConsumptionException for downstream task failure > --

[jira] [Created] (FLINK-12089) Broadcasting Dynamic Configuration

langjingxiang created FLINK-12089: - Summary: Broadcasting Dynamic Configuration Key: FLINK-12089 URL: https://issues.apache.org/jira/browse/FLINK-12089 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-12088) Introduce unbounded streaming inner join operator

Kurt Young created FLINK-12088: -- Summary: Introduce unbounded streaming inner join operator Key: FLINK-12088 URL: https://issues.apache.org/jira/browse/FLINK-12088 Project: Flink Issue Type: Imp

[jira] [Commented] (FLINK-12070) Make blocking result partitions consumable multiple times

[ https://issues.apache.org/jira/browse/FLINK-12070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808312#comment-16808312 ] BoWang commented on FLINK-12070: Totally agree with this proposal. I would like to take

[jira] [Updated] (FLINK-12087) Introduce over window operators to blink batch

[ https://issues.apache.org/jira/browse/FLINK-12087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12087: --- Labels: pull-request-available (was: ) > Introduce over window operators to blink batch > -

[GitHub] [flink] flinkbot commented on issue #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

flinkbot commented on issue #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102#issuecomment-479311696 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] JingsongLi opened a new pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch

JingsongLi opened a new pull request #8102: [FLINK-12087][table-runtime-blink] Introduce over window operators to blink batch URL: https://github.com/apache/flink/pull/8102 ## What is the purpose of the change Introduce NonBufferOverWindowOperator: Some over windows do not need to b

[jira] [Created] (FLINK-12087) Introduce over window operators to blink batch

Jingsong Lee created FLINK-12087: Summary: Introduce over window operators to blink batch Key: FLINK-12087 URL: https://issues.apache.org/jira/browse/FLINK-12087 Project: Flink Issue Type: Ne

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271556407 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/C

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271551611 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271550350 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271549409 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271553097 ## File path: flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/api/tableImpl

[jira] [Commented] (FLINK-12043) Null value check in array serializers classes

[ https://issues.apache.org/jira/browse/FLINK-12043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808292#comment-16808292 ] Quan Shi commented on FLINK-12043: -- Hi, [~yunta] I make a test on version 1.6.0. Here i

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808287#comment-16808287 ] Jiangjie Qin commented on FLINK-11912: -- [~suez1224] Thanks for the explanation. Got

[jira] [Comment Edited] (FLINK-12086) AsyncFunction - Add access to a user defined Object for cleanup on timeout

[ https://issues.apache.org/jira/browse/FLINK-12086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808282#comment-16808282 ] Guowei Ma edited comment on FLINK-12086 at 4/3/19 1:30 AM: --- I

[jira] [Commented] (FLINK-12086) AsyncFunction - Add access to a user defined Object for cleanup on timeout

[ https://issues.apache.org/jira/browse/FLINK-12086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16808282#comment-16808282 ] Guowei Ma commented on FLINK-12086: --- I think there might be another way to access user

[jira] [Closed] (FLINK-12041) Introduce ResettableExternalBuffer to blink batch

[ https://issues.apache.org/jira/browse/FLINK-12041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-12041. -- Resolution: Fixed Fix Version/s: 1.9.0 fixed in 3b817a03f49f252480a13c20098371fb3a98566c > Int

[GitHub] [flink] KurtYoung merged pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch

KurtYoung merged pull request #8066: [FLINK-12041][table-runtime-blink] Introduce ResettableExternalBuffer to blink batch URL: https://github.com/apache/flink/pull/8066 This is an automated message from the Apache Git Servic

[jira] [Updated] (FLINK-12086) AsyncFunction - Add access to a user defined Object for cleanup on timeout

[ https://issues.apache.org/jira/browse/FLINK-12086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Felix Wollschläger updated FLINK-12086: --- Description: When executing async-requests it would be nice to have access to a user

[jira] [Created] (FLINK-12086) AsyncFunction - Add access to a user defined Object for cleanup on timeout

Felix Wollschläger created FLINK-12086: -- Summary: AsyncFunction - Add access to a user defined Object for cleanup on timeout Key: FLINK-12086 URL: https://issues.apache.org/jira/browse/FLINK-12086

[jira] [Closed] (FLINK-11240) Implement external catalog factory and descriptor

[ https://issues.apache.org/jira/browse/FLINK-11240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-11240. Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: bd2dae698a068543ae270b8cb3cc5a858c8f

[GitHub] [flink] asfgit closed pull request #7390: [FLINK-11240] [table] External Catalog Factory and Descriptor

asfgit closed pull request #7390: [FLINK-11240] [table] External Catalog Factory and Descriptor URL: https://github.com/apache/flink/pull/7390 This is an automated message from the Apache Git Service. To respond to the messa

[jira] [Updated] (FLINK-11240) Implement external catalog factory and descriptor

[ https://issues.apache.org/jira/browse/FLINK-11240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-11240: - Issue Type: New Feature (was: Sub-task) Parent: (was: FLINK-10744) > Implement exte

[GitHub] [flink] flinkbot edited a comment on issue #8095: [FLINK-12078][network] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment

flinkbot edited a comment on issue #8095: [FLINK-12078][network] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment URL: https://github.com/apache/flink/pull/8095#issuecomment-478609770 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot.

[GitHub] [flink] azagrebin commented on issue #8095: [FLINK-12078][network] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment

azagrebin commented on issue #8095: [FLINK-12078][network] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment URL: https://github.com/apache/flink/pull/8095#issuecomment-479142968 @flinkbot approve all T

[GitHub] [flink] azagrebin commented on issue #8095: [FLINK-12078][network] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment

azagrebin commented on issue #8095: [FLINK-12078][network] Abstract TaskEventPublisher interface for simplifying NetworkEnvironment URL: https://github.com/apache/flink/pull/8095#issuecomment-479142820 @zhijiangW could you restart the timed out build in your CI and try to get a green build

[GitHub] [flink] tillrohrmann closed pull request #8098: [BP-1.7][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

tillrohrmann closed pull request #8098: [BP-1.7][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8098 This is an automated message from the Apache Git Service

[GitHub] [flink] tillrohrmann commented on issue #8097: [BP-1.8][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

tillrohrmann commented on issue #8097: [BP-1.8][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8097#issuecomment-479105356 Merged. This is an automated messag

[GitHub] [flink] tillrohrmann commented on issue #8098: [BP-1.7][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

tillrohrmann commented on issue #8098: [BP-1.7][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8098#issuecomment-479105442 Merged. This is an automated messag

[GitHub] [flink] tillrohrmann closed pull request #8097: [BP-1.8][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

tillrohrmann closed pull request #8097: [BP-1.8][FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8097 This is an automated message from the Apache Git Service

[jira] [Resolved] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

[ https://issues.apache.org/jira/browse/FLINK-12075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-12075. --- Resolution: Fixed Fix Version/s: 1.7.3 Fixed via master: 03499035cc3e0c3e5a5307cadd9c

[GitHub] [flink] asfgit closed pull request #8096: [FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

asfgit closed pull request #8096: [FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8096 This is an automated message from the Apache Git Service. To respond t

[GitHub] [flink] tillrohrmann commented on issue #8096: [FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

tillrohrmann commented on issue #8096: [FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8096#issuecomment-479097604 Thanks for the review @walterddr and @uce. Merging after addressing Ufuk's comments. --

[jira] [Commented] (FLINK-7730) TableFunction LEFT OUTER joins with ON predicates are broken

[ https://issues.apache.org/jira/browse/FLINK-7730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807900#comment-16807900 ] Haisheng Yuan commented on FLINK-7730: -- The Calcite issue [CALCITE-2004|https://iss

[GitHub] [flink] tillrohrmann commented on a change in pull request #8096: [FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified

tillrohrmann commented on a change in pull request #8096: [FLINK-12075][yarn] Set RestOptions.BIND_PORT only to 0 if not specified URL: https://github.com/apache/flink/pull/8096#discussion_r271383717 ## File path: flink-yarn/src/test/java/org/apache/flink/yarn/entrypoint/YarnEntryp

[jira] [Commented] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807880#comment-16807880 ] Xingcan Cui commented on FLINK-7865: Thanks for working on that, [~hyuan] ! I'll take

[jira] [Commented] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807877#comment-16807877 ] Haisheng Yuan commented on FLINK-7865: -- The blocker is resolved in Calcite 1.20. >

[jira] [Assigned] (FLINK-7865) Remove predicate restrictions on TableFunction left outer join

[ https://issues.apache.org/jira/browse/FLINK-7865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7865: -- Assignee: Xingcan Cui > Remove predicate restrictions on TableFunction left outer join > -

[jira] [Created] (FLINK-12085) Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint'

Jacky Yin created FLINK-12085: - Summary: Improve Mesos job cluster entry point 'MesosJobClusterEntrypoint' Key: FLINK-12085 URL: https://issues.apache.org/jira/browse/FLINK-12085 Project: Flink

[GitHub] [flink] dawidwys commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

dawidwys commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271361144 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/Columns

[GitHub] [flink] dawidwys commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

dawidwys commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271361144 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/Columns

[GitHub] [flink] dawidwys merged pull request #8080: [hotfix][runtime] Improve exception message in SingleInputGate

dawidwys merged pull request #8080: [hotfix][runtime] Improve exception message in SingleInputGate URL: https://github.com/apache/flink/pull/8080 This is an automated message from the Apache Git Service. To respond to the me

[jira] [Closed] (FLINK-12014) Flink CEP Doc missing "SkipToNextStrategy"

[ https://issues.apache.org/jira/browse/FLINK-12014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-12014. Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 8a56b8943865d42fa6479e5f3cc5bbd1f21

[jira] [Updated] (FLINK-12014) Flink CEP Doc missing "SkipToNextStrategy"

[ https://issues.apache.org/jira/browse/FLINK-12014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-12014: - Priority: Minor (was: Major) > Flink CEP Doc missing "SkipToNextStrategy" > ---

[GitHub] [flink] dawidwys merged pull request #8049: [FLINK-12014][Doc]Flink CEP Doc missing "SkipToNextStrategy"

dawidwys merged pull request #8049: [FLINK-12014][Doc]Flink CEP Doc missing "SkipToNextStrategy" URL: https://github.com/apache/flink/pull/8049 This is an automated message from the Apache Git Service. To respond to the mess

[GitHub] [flink] dawidwys commented on issue #8049: [FLINK-12014][Doc]Flink CEP Doc missing "SkipToNextStrategy"

dawidwys commented on issue #8049: [FLINK-12014][Doc]Flink CEP Doc missing "SkipToNextStrategy" URL: https://github.com/apache/flink/pull/8049#issuecomment-479041274 Sorry @Tom-Goong, my mistake, didn't spot it. +1, merging ---

[jira] [Closed] (FLINK-12020) Add documentation for mesos-appmaster-job.sh

[ https://issues.apache.org/jira/browse/FLINK-12020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-12020. - Resolution: Fixed Fix Version/s: 1.8.0 1.7.3 Fixed via 1.9.0: b36bca8a

[GitHub] [flink] asfgit closed pull request #8084: [FLINK-12020] [Deployment/Mesos/Documentation] Add documentation for mesos-appmaster-job.sh

asfgit closed pull request #8084: [FLINK-12020] [Deployment/Mesos/Documentation] Add documentation for mesos-appmaster-job.sh URL: https://github.com/apache/flink/pull/8084 This is an automated message from the Apache Git Se

[jira] [Commented] (FLINK-12075) Not able to submit jobs on YARN when there's a firewall

[ https://issues.apache.org/jira/browse/FLINK-12075?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807818#comment-16807818 ] Aljoscha Krettek commented on FLINK-12075: -- Thanks for testing this on short no

[jira] [Closed] (FLINK-12083) Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath.

[ https://issues.apache.org/jira/browse/FLINK-12083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kelun wang closed FLINK-12083. -- Resolution: Invalid > Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which > ha

[jira] [Updated] (FLINK-12083) Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath.

[ https://issues.apache.org/jira/browse/FLINK-12083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kelun wang updated FLINK-12083: --- Attachment: (was: image-2019-04-02-22-24-40-700.png) > Sink into Hbase, one of the task(slot) fa

[jira] [Updated] (FLINK-12083) Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath.

[ https://issues.apache.org/jira/browse/FLINK-12083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kelun wang updated FLINK-12083: --- Description: (was: Hello, I'm running a flink job that write data into hbase ,but one of the tas

[jira] [Created] (FLINK-12084) Flink API extensions do not seems to include split method

Jacopo Gobbi created FLINK-12084: Summary: Flink API extensions do not seems to include split method Key: FLINK-12084 URL: https://issues.apache.org/jira/browse/FLINK-12084 Project: Flink Iss

[jira] [Created] (FLINK-12083) Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath.

kelun wang created FLINK-12083: -- Summary: Sink into Hbase, one of the task(slot) failed to read hbase-site.xml which has already added into classpath. Key: FLINK-12083 URL: https://issues.apache.org/jira/browse/FLINK

[GitHub] [flink] hequn8128 commented on issue #8087: [FLINK-12029][table] Add column operations for TableApi

hequn8128 commented on issue #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#issuecomment-479021520 @sunjincheng121 Thanks for your valuable suggestions. It makes the PR much better. I have addressed all your comments and update

[jira] [Comment Edited] (FLINK-12037) High parallelism E2E test failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-12037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16806596#comment-16806596 ] Guowei Ma edited comment on FLINK-12037 at 4/2/19 1:29 PM: --- >F

[GitHub] [flink] pengkangjing commented on a change in pull request #8060: [FLINK-12021] Deploy execution in topological sorted order

pengkangjing commented on a change in pull request #8060: [FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8060#discussion_r271297840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java

[GitHub] [flink] pengkangjing commented on a change in pull request #8060: [FLINK-12021] Deploy execution in topological sorted order

pengkangjing commented on a change in pull request #8060: [FLINK-12021] Deploy execution in topological sorted order URL: https://github.com/apache/flink/pull/8060#discussion_r271297840 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/concurrent/FutureUtils.java

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271286544 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/C

[GitHub] [flink] hequn8128 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

hequn8128 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271282393 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/Column

[GitHub] [flink] sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

sunjincheng121 commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271279312 ## File path: flink-table/flink-table-common/src/main/java/org/apache/flink/table/expressions/Bui

[GitHub] [flink] flinkbot commented on issue #8101: [hotfix][docs] fix error in Process Function Doc

flinkbot commented on issue #8101: [hotfix][docs] fix error in Process Function Doc URL: https://github.com/apache/flink/pull/8101#issuecomment-478966308 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request.

[GitHub] [flink] zsq12138 opened a new pull request #8101: [hotfix][docs] fix error in Process Function Doc

zsq12138 opened a new pull request #8101: [hotfix][docs] fix error in Process Function Doc URL: https://github.com/apache/flink/pull/8101 ## What is the purpose of the change In the example given,it used the `ProcessFunction` on a keyed stream. But in the new version, it has bee

[jira] [Commented] (FLINK-8801) S3's eventual consistent read-after-write may fail yarn deployment of resources to S3

[ https://issues.apache.org/jira/browse/FLINK-8801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16807691#comment-16807691 ] Tao Yang commented on FLINK-8801: - Hi, [~NicoK].  I have doubt about this PR which direc

[GitHub] [flink] dawidwys commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi

dawidwys commented on a change in pull request #8087: [FLINK-12029][table] Add column operations for TableApi URL: https://github.com/apache/flink/pull/8087#discussion_r271265913 ## File path: flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/expressions/Columns

  1   2   >