[jira] [Assigned] (FLINK-9119) example code error in Concepts & Common API

[vinoyang (JIRA)]

 [ 
https://issues.apache.org/jira/browse/FLINK-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

vinoyang reassigned FLINK-9119:
---

Assignee: vinoyang

> example code error in Concepts & Common API
> ---
>
> Key: FLINK-9119
> URL: https://issues.apache.org/jira/browse/FLINK-9119
> Project: Flink
>  Issue Type: Bug
>  Components: Documentation
>Affects Versions: 1.4.2
>Reporter: chillon.m
>Assignee: vinoyang
>Priority: Minor
>
> // Table is the result of a simple projection query Table projTable = 
> tableEnv.scan("X").project(...);
> {{scan return a table object,not have a project method.}}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

[jira] [Assigned] (FLINK-8880) Validate configurations for SQL Client

[Rong Rong (JIRA)]

 [ 
https://issues.apache.org/jira/browse/FLINK-8880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Rong Rong reassigned FLINK-8880:


Assignee: Rong Rong

> Validate configurations for SQL Client
> --
>
> Key: FLINK-8880
> URL: https://issues.apache.org/jira/browse/FLINK-8880
> Project: Flink
>  Issue Type: Sub-task
>  Components: Table API  SQL
>Reporter: Xingcan Cui
>Assignee: Rong Rong
>Priority: Major
>
> Currently, the configuration items for SQL client are stored in maps and 
> accessed with default values. They should be validated when creating the 
> client. Also, logger warnings should be shown when using default values.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

[GitHub] flink pull request #5797: [Flink 9104][doc]Re-generate REST API documentatio...

[walterddr]

GitHub user walterddr opened a pull request:

https://github.com/apache/flink/pull/5797

[Flink 9104][doc]Re-generate REST API documentation for FLIP-6

## What is the purpose of the change

Fix REST-API doc generator and regenerate rest_dispatcher.html

## Brief change log

- Changes according to FLINK-8843
- Escape HTML characters

## Verifying this change

N/A

## Does this pull request potentially affect one of the following parts:

no

## Documentation

docs updated


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/walterddr/flink FLINK-9104

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/5797.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #5797


commit a5ad88f7fa8200cea5084b6d630592bc473a9b6a
Author: Rong Rong 
Date:   2018-03-31T19:29:59Z

fix REST API doc generator bug and regenerate rest_dispatcher




---

[GitHub] flink issue #5796: [Flink 9104][doc]Re-generate REST API documentation for F...

[walterddr]

Github user walterddr commented on the issue:

https://github.com/apache/flink/pull/5796
  
Wrong base


---

[GitHub] flink pull request #5796: [Flink 9104][doc]Re-generate REST API documentatio...

[walterddr]

Github user walterddr closed the pull request at:

https://github.com/apache/flink/pull/5796


---

[GitHub] flink pull request #5796: [Flink 9104][doc]Re-generate REST API documentatio...

[walterddr]

GitHub user walterddr opened a pull request:

https://github.com/apache/flink/pull/5796

[Flink 9104][doc]Re-generate REST API documentation for FLIP-6


## What is the purpose of the change

Fix REST-API doc generator and regenerate rest_dispatcher.html

## Brief change log

- Changes according to FLINK-8843
- Escape HTML characters

## Verifying this change

N/A

## Does this pull request potentially affect one of the following parts:

no

## Documentation

docs updated


You can merge this pull request into a Git repository by running:

$ git pull https://github.com/walterddr/flink FLINK-9104

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/flink/pull/5796.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #5796


commit 8eb6a30798c09d171e3eb8019b53e677252bd5ba
Author: Piotr Nowojski 
Date:   2018-02-23T10:28:20Z

[FLINK-8694][runtime] Fix notifyDataAvailable race condition

Before there was a race condition that might resulted in igonoring some 
notifyDataAvailable calls.
This fixes the problem by moving buffersAvailable handling to Supartitions 
and adds stress test
for flushAlways (without this fix this test is dead locking).

(cherry picked from commit ebd39f3)

commit 61a34a691e7d5233f18ac72a1ab8fb09b53c4753
Author: Piotr Nowojski 
Date:   2018-02-26T15:13:06Z

[FLINK-8805][runtime] Optimize EvenSerializer.isEvent method

For example, previously if the method was used to check for 
EndOfPartitionEvent
and the Buffer contained huge custom event, the even had to be deserialized 
before
performing the actual check. Now we are quickly entering the correct 
if/else branch
and doing full costly deserialization only if we have to.

Other calls to isEvent() then checking against EndOfPartitionEvent were not 
used.

(cherry picked from commit 767027f)

commit d5338c4154e5de029b3b30e3ef0a0732bf7f68e7
Author: Piotr Nowojski 
Date:   2018-02-27T09:39:00Z

[FLINK-8750][runtime] Improve detection of no remaining data after 
EndOfPartitionEvent

Because of race condition between:
  1. releasing inputChannelsWithData lock in this method and reaching this 
place
  2. empty data notification that re-enqueues a channel
we can end up with moreAvailable flag set to true, while we expect no more 
data.

This commit detects such situation, makes a correct assertion and turn off 
moreAvailable flag.

(cherry picked from commit b9b7416)

commit 32384ed9b00cf0e1961d355dc4080f25a2156e58
Author: Zhijiang 
Date:   2018-02-22T14:41:38Z

[FLINK-8747][bugfix] The tag of waiting for floating buffers in 
RemoteInputChannel should be updated properly

(cherry picked from commit 6e9e0dd)

commit f1453276095c55264f7b4097d16e2987a44b3f33
Author: Zhijiang 
Date:   2018-02-23T01:55:57Z

[hotfix] Fix package private and comments

(cherry picked from commit 6165b3d)

commit 18ff2ce15bdb1e7bd246e438e47527a24559c86d
Author: Nico Kruber 
Date:   2018-02-26T16:50:10Z

[hotfix][network] minor improvements in UnionInputGate

(cherry picked from commit 4203557)

commit 9265666517830350a4a7037029e347f33df1bea2
Author: Nico Kruber 
Date:   2018-02-26T16:52:37Z

[FLINK-8737][network] disallow creating a union of UnionInputGate instances

Recently, the pollNextBufferOrEvent() was added but not implemented but 
this is
used in getNextBufferOrEvent() and thus any UnionInputGate containing a 
UnionInputGate
would have failed already. There should be no use case for wiring up inputs
this way. Therefore, fail early when trying to construct this.

(cherry picked from commit e8de538)

commit 26c8f6c2a3ff75ffb954c816a57908318a2d8099
Author: Stephan Ewen 
Date:   2018-02-28T11:15:30Z

[hotfix] [tests] Fix SelfConnectionITCase

The test previously did not fail on failed execution, and thus evaluated 
incomplete results
from a failed execution with th expected results.

This cleans up serialization warnings and uses lambdas where possible, to 
make the code
more readable.

commit f60e46dafa8950d5e40cd8a3286c172ecaea6b73
Author: gyao 
Date:   2018-02-28T12:04:19Z

[hotfix] Add missing space to log message in ZooKeeperLeaderElectionService

commit b7247929d0745b3b83306d0c93d97faf4ece4107
Author: gyao 
Date:   2018-02-28T12:06:00Z

[hotfix][Javadoc] Fix typo in YARN Utils: teh -> the

commit adb3750226971f7c67a0d3069103b56e4fee1c27
Author: gyao 
Date:   2018-02-28T12:07:04Z

[hotfix][Javadoc] Fix typo in YarnTestBase: teh -> the

commit 

[jira] [Updated] (FLINK-9119) example code error in Concepts & Common API

[chillon.m (JIRA)]

 [ 
https://issues.apache.org/jira/browse/FLINK-9119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

chillon.m updated FLINK-9119:
-
Description: 
// Table is the result of a simple projection query Table projTable = 
tableEnv.scan("X").project(...);

{{scan return a table object,not have a project method.}}

  was:
// Table is the result of a simple projection query  Table projTable = 
tableEnv.scan("X").project(...);

{{scan return a table object,not have a project method.I don't find project() 
method return a table object.}}


> example code error in Concepts & Common API
> ---
>
> Key: FLINK-9119
> URL: https://issues.apache.org/jira/browse/FLINK-9119
> Project: Flink
>  Issue Type: Bug
>  Components: Documentation
>Affects Versions: 1.4.2
>Reporter: chillon.m
>Priority: Minor
>
> // Table is the result of a simple projection query Table projTable = 
> tableEnv.scan("X").project(...);
> {{scan return a table object,not have a project method.}}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

[jira] [Created] (FLINK-9119) example code error in Concepts & Common API

[chillon.m (JIRA)]

chillon.m created FLINK-9119:


 Summary: example code error in Concepts & Common API
 Key: FLINK-9119
 URL: https://issues.apache.org/jira/browse/FLINK-9119
 Project: Flink
  Issue Type: Bug
  Components: Documentation
Affects Versions: 1.4.2
Reporter: chillon.m


// Table is the result of a simple projection query  Table projTable = 
tableEnv.scan("X").project(...);

{{scan return a table object,not have a project method.I don't find project() 
method return a table object.}}



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)