[GitHub] [flink] zhijiangW commented on a change in pull request #8857: [FLINK-12960][coordination][shuffle] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#relea

zhijiangW commented on a change in pull request #8857: [FLINK-12960][coordination][shuffle] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption URL: https://github.com/apache/flink/pull/8857#discussion_r297529541 ## File

[jira] [Commented] (FLINK-12536) Make BufferOrEventSequence#getNext() non-blocking

[ https://issues.apache.org/jira/browse/FLINK-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873088#comment-16873088 ] Congxian Qiu(klion26) commented on FLINK-12536: --- As discussed with [~pnowojski] offline,

[GitHub] [flink] liyafan82 commented on a change in pull request #8757: [FLINK-12850][core] Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime

liyafan82 commented on a change in pull request #8757: [FLINK-12850][core] Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime URL: https://github.com/apache/flink/pull/8757#discussion_r297546738 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM

zentol commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM URL: https://github.com/apache/flink/pull/8778#discussion_r297555765 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java ## @@

[GitHub] [flink] pnowojski closed pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder

pnowojski closed pull request #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder URL: https://github.com/apache/flink/pull/8199 This is an automated message from the Apache Git Service. To

[GitHub] [flink] pnowojski commented on issue #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder

pnowojski commented on issue #8199: [FLINK-11955] Modify build to move filesystems from lib to plugins folder URL: https://github.com/apache/flink/pull/8199#issuecomment-505795217 > I think there is a value in relocating the fs plugins done together with un-shading them (FLINK-11956).

[GitHub] [flink] liyafan82 commented on a change in pull request #8757: [FLINK-12850][core] Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime

liyafan82 commented on a change in pull request #8757: [FLINK-12850][core] Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime URL: https://github.com/apache/flink/pull/8757#discussion_r297571612 ## File path:

[jira] [Closed] (FLINK-12612) Track stored partitions on the TM

[ https://issues.apache.org/jira/browse/FLINK-12612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12612. Resolution: Fixed master: 847e7e79387b0347015733fdfacb0595e00bcda0 > Track stored

[GitHub] [flink] dianfu commented on issue #8715: [FLINK-12821][table][cep] Fix the bug that fix time quantifier can not be the last element of a pattern

dianfu commented on issue #8715: [FLINK-12821][table][cep] Fix the bug that fix time quantifier can not be the last element of a pattern URL: https://github.com/apache/flink/pull/8715#issuecomment-505799482 @dawidwys thanks a lot for the review and commit. :)

[GitHub] [flink] yanghua closed pull request #8684: [FLINK-12790] Implement KeyScope enum to distinguish the key of localKeyBy and general keyBy API

yanghua closed pull request #8684: [FLINK-12790] Implement KeyScope enum to distinguish the key of localKeyBy and general keyBy API URL: https://github.com/apache/flink/pull/8684 This is an automated message from the Apache

[GitHub] [flink] dianfu commented on issue #8892: [FLINK-FLINK-12990][python] Date type doesn't consider the local TimeZone

dianfu commented on issue #8892: [FLINK-FLINK-12990][python] Date type doesn't consider the local TimeZone URL: https://github.com/apache/flink/pull/8892#issuecomment-505802703 @sunjincheng121 Makes sense and I will add some test cases.

[GitHub] [flink] yanghua commented on issue #8684: [FLINK-12790] Implement KeyScope enum to distinguish the key of localKeyBy and general keyBy API

yanghua commented on issue #8684: [FLINK-12790] Implement KeyScope enum to distinguish the key of localKeyBy and general keyBy API URL: https://github.com/apache/flink/pull/8684#issuecomment-505802673 @pnowojski I opened this PR before @aljoscha ask me to create FLIP. So I also think it

[jira] [Updated] (FLINK-12960) Introduce ShuffleDescriptor#ReleaseType

[ https://issues.apache.org/jira/browse/FLINK-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12960: Summary: Introduce ShuffleDescriptor#ReleaseType (was: Move

[jira] [Updated] (FLINK-12960) Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption

[ https://issues.apache.org/jira/browse/FLINK-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12960: Description: {{ResultPartitionDeploymentDescriptor#releasedOnConsumption}}  shows the

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297592199 ## File path:

[jira] [Commented] (FLINK-11956) Remove shading from filesystems build

[ https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873244#comment-16873244 ] Chesnay Schepler commented on FLINK-11956: -- Are all of our filesystems compatible with the

[jira] [Comment Edited] (FLINK-11956) Remove shading from filesystems build

[ https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873247#comment-16873247 ] Piotr Nowojski edited comment on FLINK-11956 at 6/26/19 11:40 AM: -- We

[jira] [Created] (FLINK-13001) Add ExecutionGraphBuilder for testing

Chesnay Schepler created FLINK-13001: Summary: Add ExecutionGraphBuilder for testing Key: FLINK-13001 URL: https://issues.apache.org/jira/browse/FLINK-13001 Project: Flink Issue Type:

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r297633905 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,168 @@ +--- +title: Glossary

[jira] [Commented] (FLINK-10879) Align Flink clients on env.execute()

[ https://issues.apache.org/jira/browse/FLINK-10879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873283#comment-16873283 ] TisonKun commented on FLINK-10879: -- [~f.pompermaier] I suspect if you deploy a job cluster ant code

[jira] [Commented] (FLINK-10879) Align Flink clients on env.execute()

[ https://issues.apache.org/jira/browse/FLINK-10879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873295#comment-16873295 ] TisonKun commented on FLINK-10879: -- Well I can see the "REST API" ways now. It compiles the job via

[jira] [Assigned] (FLINK-12023) Override TaskManager memory when submitting a Flink job

[ https://issues.apache.org/jira/browse/FLINK-12023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-12023: Assignee: (was: vinoyang) > Override TaskManager memory when submitting a Flink job >

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297531579 ## File path: flink-python/pyflink/find_flink_home.py ## @@ -15,12 +16,21 @@ # See the

[GitHub] [flink] zentol opened a new pull request #8896: [FLINK-12993][runtime] Refactor forceReleaseOnConsumption to JM concept

zentol opened a new pull request #8896: [FLINK-12993][runtime] Refactor forceReleaseOnConsumption to JM concept URL: https://github.com/apache/flink/pull/8896 The `forceReleaseOnConsumption` flag allows us to switch between the current behavior (all partitions are released on consumption)

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297546146 ## File path: flink-dist/src/main/flink-bin/bin/pyflink-shell.sh ## @@ -18,8 +18,13 @@

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297526228 ## File path: flink-python/pyflink/shell.py ## @@ -15,7 +15,10 @@ # See the License for the

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297540088 ## File path: flink-python/pyflink/find_flink_home.py ## @@ -1,4 +1,5 @@

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297532944 ## File path: flink-python/pyflink/find_flink_home.py ## @@ -30,12 +40,31 @@ def

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297543943 ## File path: flink-python/MANIFEST.in ## @@ -0,0 +1,29 @@

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297519065 ## File path: flink-python/setup.py ## @@ -42,31 +44,165 @@ with

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297460497 ## File path: flink-python/setup.py ## @@ -42,31 +44,165 @@ with

[GitHub] [flink] dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed.

dianfu commented on a change in pull request #8863: [FLINK-12962][python] Allows pyflink to be pip installed. URL: https://github.com/apache/flink/pull/8863#discussion_r297550056 ## File path: flink-dist/src/main/flink-bin/bin/config.sh ## @@ -296,7 +296,10 @@

[jira] [Commented] (FLINK-12953) View logs from Job view in Web Dashboard

[ https://issues.apache.org/jira/browse/FLINK-12953?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873121#comment-16873121 ] Robert Metzger commented on FLINK-12953: [~chadrik] thanks a lot for opening this ticket! I

[jira] [Commented] (FLINK-12786) Implement local aggregation in Flink

[ https://issues.apache.org/jira/browse/FLINK-12786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873162#comment-16873162 ] vinoyang commented on FLINK-12786: -- Now, the main discussers in the community are me and the developers

[GitHub] [flink] pnowojski commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

pnowojski commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#discussion_r297579509 ## File path:

[GitHub] [flink] zentol merged pull request #8857: [FLINK-12960] Introduce ShuffleDescriptor#ReleaseType and ShuffleDescriptor#getSupportedReleaseTypes

zentol merged pull request #8857: [FLINK-12960] Introduce ShuffleDescriptor#ReleaseType and ShuffleDescriptor#getSupportedReleaseTypes URL: https://github.com/apache/flink/pull/8857 This is an automated message from the

[GitHub] [flink] zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zhijiangW commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r297581901 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

pnowojski commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#discussion_r297581797 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter

pnowojski commented on a change in pull request #8621: [FLINK-12682][connectors] StringWriter support custom row delimiter URL: https://github.com/apache/flink/pull/8621#discussion_r297580610 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r297636397 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,168 @@ +--- +title: Glossary

[GitHub] [flink] leesf opened a new pull request #8899: [hotfix][readme] fix how to contribute to Apache Flink url

leesf opened a new pull request #8899: [hotfix][readme] fix how to contribute to Apache Flink url URL: https://github.com/apache/flink/pull/8899 *Fix url error in README.md* cc @zentol @fhueske This is an

[GitHub] [flink] zhijiangW commented on a change in pull request #8857: [FLINK-12960][coordination][shuffle] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#relea

zhijiangW commented on a change in pull request #8857: [FLINK-12960][coordination][shuffle] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption URL: https://github.com/apache/flink/pull/8857#discussion_r297530334 ## File

[jira] [Assigned] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11767: Assignee: (was: Tzu-Li (Gordon) Tai) > Update TypeSerializerSnapshotMigrationTestBase and

[jira] [Commented] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873067#comment-16873067 ] vinoyang commented on FLINK-11767: -- I have released the assignee. > Update

[jira] [Assigned] (FLINK-11767) Update TypeSerializerSnapshotMigrationTestBase and subclasses for 1.8

[ https://issues.apache.org/jira/browse/FLINK-11767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11767: Assignee: Tzu-Li (Gordon) Tai (was: vinoyang) > Update TypeSerializerSnapshotMigrationTestBase

[GitHub] [flink] ifndef-SleePy opened a new pull request #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter

ifndef-SleePy opened a new pull request #8894: [FLINK-12961][datastream] Providing an internal execution method of StreamExecutionEnvironment accepting StreamGraph as input parameter URL: https://github.com/apache/flink/pull/8894 ## What is the purpose of the change * Expose an

[jira] [Updated] (FLINK-12961) StreamExecutionEnvironment supports executing job with StreamGraph

[ https://issues.apache.org/jira/browse/FLINK-12961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12961: --- Labels: pull-request-available (was: ) > StreamExecutionEnvironment supports executing job

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297538465 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

zhuzhurk commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297567190 ## File path:

[jira] [Closed] (FLINK-11955) Modify build to move filesystems from lib to plugins folder

[ https://issues.apache.org/jira/browse/FLINK-11955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-11955. -- Resolution: Invalid Users were always expected to move the file system jars manually from

[GitHub] [flink] flinkbot edited a comment on issue #8893: [hotfix][python] Align the signature of type utility methods with Java

flinkbot edited a comment on issue #8893: [hotfix][python] Align the signature of type utility methods with Java URL: https://github.com/apache/flink/pull/8893#issuecomment-505713502 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] sunjincheng121 commented on issue #8893: [hotfix][python] Align the signature of type utility methods with Java

sunjincheng121 commented on issue #8893: [hotfix][python] Align the signature of type utility methods with Java URL: https://github.com/apache/flink/pull/8893#issuecomment-505801756 @flinkbot approve all This is an automated

[GitHub] [flink] alpinegizmo commented on issue #8607: [FLINK-12652] [documentation] add first version of a glossary

alpinegizmo commented on issue #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#issuecomment-505807000 For a first version, this looks quite good already. Are we collecting somewhere a list of terms that might be added at

[GitHub] [flink] liyafan82 commented on a change in pull request #8757: [FLINK-12850][core] Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime

liyafan82 commented on a change in pull request #8757: [FLINK-12850][core] Introduce TypeInfo for LocalDate/LocalTime/LocalDateTime URL: https://github.com/apache/flink/pull/8757#discussion_r297586451 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8846: [FLINK-12766][runtime] Dynamically allocate TaskExecutor's managed memory to slots.

gaoyunhaii commented on a change in pull request #8846: [FLINK-12766][runtime] Dynamically allocate TaskExecutor's managed memory to slots. URL: https://github.com/apache/flink/pull/8846#discussion_r297586457 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #8846: [FLINK-12766][runtime] Dynamically allocate TaskExecutor's managed memory to slots.

gaoyunhaii commented on a change in pull request #8846: [FLINK-12766][runtime] Dynamically allocate TaskExecutor's managed memory to slots. URL: https://github.com/apache/flink/pull/8846#discussion_r297586457 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread

1u0 commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread URL: https://github.com/apache/flink/pull/8858#discussion_r297592011 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic

zhijiangW commented on a change in pull request #8804: [FLINK-12883][WIP][runtime] Add elaborated partition release logic URL: https://github.com/apache/flink/pull/8804#discussion_r297592199 ## File path:

[jira] [Updated] (FLINK-11956) Remove shading from filesystems build

[ https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-11956: --- Priority: Blocker (was: Major) > Remove shading from filesystems build >

[jira] [Commented] (FLINK-11956) Remove shading from filesystems build

[ https://issues.apache.org/jira/browse/FLINK-11956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873211#comment-16873211 ] Piotr Nowojski commented on FLINK-11956: I think we should decide how do we want to proceed with

[GitHub] [flink] 1u0 commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread

1u0 commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread URL: https://github.com/apache/flink/pull/8858#discussion_r29760 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread

1u0 commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread URL: https://github.com/apache/flink/pull/8858#discussion_r297609906 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r297632384 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,168 @@ +--- +title: Glossary

[GitHub] [flink] zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r297632721 ## File path:

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r297632771 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,168 @@ +--- +title: Glossary

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r297632737 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,168 @@ +--- +title: Glossary

[jira] [Closed] (FLINK-12914) Remove legacy InstanceListener

[ https://issues.apache.org/jira/browse/FLINK-12914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-12914. Resolution: Fixed master: 126a489e20f4743c361bbf2f2b4a2c890f8026ab > Remove legacy

[GitHub] [flink] 1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox

1u0 commented on a change in pull request #8826: [FLINK-12479][operators] Integrate StreamInputProcessor(s) with mailbox URL: https://github.com/apache/flink/pull/8826#discussion_r297625182 ## File path:

[jira] [Resolved] (FLINK-12957) Fix thrift and protobuf dependency examples in documentation

[ https://issues.apache.org/jira/browse/FLINK-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber resolved FLINK-12957. - Resolution: Fixed Fix Version/s: 1.8.1 1.7.3 merged into: - 1.8:

[jira] [Closed] (FLINK-12957) Fix thrift and protobuf dependency examples in documentation

[ https://issues.apache.org/jira/browse/FLINK-12957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nico Kruber closed FLINK-12957. --- > Fix thrift and protobuf dependency examples in documentation >

[GitHub] [flink] zhijiangW commented on a change in pull request #8857: [FLINK-12960][coordination][shuffle] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#relea

zhijiangW commented on a change in pull request #8857: [FLINK-12960][coordination][shuffle] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption URL: https://github.com/apache/flink/pull/8857#discussion_r297532281 ## File

[jira] [Commented] (FLINK-5018) Make source idle timeout user configurable

[ https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873065#comment-16873065 ] vinoyang commented on FLINK-5018: - If we do not try to take effort on this issue and open this config

[jira] [Closed] (FLINK-12971) Remove the constraint that lookup join needs a primary key or index key

[ https://issues.apache.org/jira/browse/FLINK-12971?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-12971. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: cb922bbfa0a26e147638d22aeceaf3e83b01e1d3 >

[GitHub] [flink] klion26 opened a new pull request #8895: [FLINK-12536][coordinator]Make BufferOrEventSequence#getNext non blocking

klion26 opened a new pull request #8895: [FLINK-12536][coordinator]Make BufferOrEventSequence#getNext non blocking URL: https://github.com/apache/flink/pull/8895 ## What is the purpose of the change Currently it is non-blocking in case of credit-based flow control (default),

[jira] [Updated] (FLINK-12536) Make BufferOrEventSequence#getNext() non-blocking

[ https://issues.apache.org/jira/browse/FLINK-12536?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12536: --- Labels: pull-request-available (was: ) > Make BufferOrEventSequence#getNext() non-blocking

[GitHub] [flink] GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler

GJL commented on a change in pull request #8851: [FLINK-12876] [runtime] Add an adapter of region failover NG for legacy scheduler URL: https://github.com/apache/flink/pull/8851#discussion_r297556096 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297561629 ## File path:

[jira] [Closed] (FLINK-12821) Fix the bug that fix time quantifier can not be the last element of a pattern

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

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297555970 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297561629 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297553510 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297555970 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297534362 ## File path:

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297534771 ## File path:

[GitHub] [flink] dawidwys merged pull request #8715: [FLINK-12821][table][cep] Fix the bug that fix time quantifier can not be the last element of a pattern

dawidwys merged pull request #8715: [FLINK-12821][table][cep] Fix the bug that fix time quantifier can not be the last element of a pattern URL: https://github.com/apache/flink/pull/8715 This is an automated message from

[GitHub] [flink] 1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint

1u0 commented on a change in pull request #8741: [FLINK-12752] Add Option to Pass Seed for JobID Hash for StandaloneJobClusterEntrypoint URL: https://github.com/apache/flink/pull/8741#discussion_r297541840 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r297569347 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r297572793 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager

zentol commented on a change in pull request #8646: [FLINK-12735][network] Make shuffle environment implementation independent with IOManager URL: https://github.com/apache/flink/pull/8646#discussion_r297567048 ## File path:

[GitHub] [flink] becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE)

becketqin commented on issue #6594: [FLINK-9311] [pubsub] Added PubSub source connector with support for checkpointing (ATLEAST_ONCE) URL: https://github.com/apache/flink/pull/6594#issuecomment-505800856 @Xeli Yeah, let's do that. I can give a final pass on the patch after you merge the

[jira] [Commented] (FLINK-10862) REST API does not show program descriptions of "simple" ProgramDescription

[ https://issues.apache.org/jira/browse/FLINK-10862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873164#comment-16873164 ] TisonKun commented on FLINK-10862: -- Also I find it useless {{Program}} is. How can users defined how to

[jira] [Updated] (FLINK-12960) Introduce ShuffleDescriptor#ReleaseType and ShuffleDescriptor#getSupportedReleaseTypes

[ https://issues.apache.org/jira/browse/FLINK-12960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-12960: Summary: Introduce ShuffleDescriptor#ReleaseType and

[GitHub] [flink] zentol commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM

zentol commented on a change in pull request #8778: [FLINK-12615][coordination] Track partitions on JM URL: https://github.com/apache/flink/pull/8778#discussion_r297603449 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PartitionTracker.java

[jira] [Updated] (FLINK-12998) Document Plugins mechanism

[ https://issues.apache.org/jira/browse/FLINK-12998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-12998: --- Description: Plugins mechanism must be documented before the release. We should write down:

[GitHub] [flink] knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary

knaufk commented on a change in pull request #8607: [FLINK-12652] [documentation] add first version of a glossary URL: https://github.com/apache/flink/pull/8607#discussion_r297635084 ## File path: docs/concepts/glossary.md ## @@ -0,0 +1,168 @@ +--- +title: Glossary

[GitHub] [flink] azagrebin commented on a change in pull request #8896: [FLINK-12993][runtime] Refactor forceReleaseOnConsumption to JM concept

azagrebin commented on a change in pull request #8896: [FLINK-12993][runtime] Refactor forceReleaseOnConsumption to JM concept URL: https://github.com/apache/flink/pull/8896#discussion_r297633733 ## File path:

[jira] [Commented] (FLINK-12176) Unify JobGraph creation in CliFrontend

[ https://issues.apache.org/jira/browse/FLINK-12176?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16873287#comment-16873287 ] TisonKun commented on FLINK-12176: -- [~till.rohrmann] I can see your concern now because

[GitHub] [flink] aljoscha commented on a change in pull request #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/

aljoscha commented on a change in pull request #8852: [FLINK-12798][table-api][table-planner] Add a proper discover mechanism that will enable switching between Flink & Blink Planner/Executor URL: https://github.com/apache/flink/pull/8852#discussion_r297529895 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread

pnowojski commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread URL: https://github.com/apache/flink/pull/8858#discussion_r297531416 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread

pnowojski commented on a change in pull request #8858: [hotfix][tests] Change some StreamTask tests to create a test task in the task's thread URL: https://github.com/apache/flink/pull/8858#discussion_r297528668 ## File path:

  1   2   3   4   5   6   >