[jira] [Commented] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199824#comment-16199824 ] Xingcan Cui commented on FLINK-7798: Hi [~fhueske], as you said, most of the related code has already

[jira] [Created] (FLINK-7802) Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource

godfrey he created FLINK-7802: - Summary: Bug in PushProjectIntoTableSourceScanRule when empty field collection was pushed into TableSource Key: FLINK-7802 URL: https://issues.apache.org/jira/browse/FLINK-7802

[jira] [Commented] (FLINK-7661) Add credit field in PartitionRequest message

[ https://issues.apache.org/jira/browse/FLINK-7661?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199749#comment-16199749 ] ASF GitHub Bot commented on FLINK-7661: --- Github user zhijiangW commented on the issue:

[GitHub] flink issue #4698: [FLINK-7661][network] Add credit field in PartitionReques...

Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/4698 @zentol , I have rebased the latest master codes and solved the conflicts. ---

[GitHub] flink issue #3478: Flink 4816 Executions failed from "DEPLOYING" should reta...

Github user tony810430 commented on the issue: https://github.com/apache/flink/pull/3478 Hi @ramkrish86 Are you still working on this PR? ---

[jira] [Commented] (FLINK-7423) Always reuse an instance to get elements from the inputFormat

[ https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199716#comment-16199716 ] ASF GitHub Bot commented on FLINK-7423: --- Github user XuPingyong closed the pull request at:

[jira] [Assigned] (FLINK-7798) Add support for windowed joins to Table API

[ https://issues.apache.org/jira/browse/FLINK-7798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-7798: -- Assignee: Xingcan Cui > Add support for windowed joins to Table API >

[GitHub] flink pull request #4525: [FLINK-7423] Always reuse an instance to get eleme...

Github user XuPingyong closed the pull request at: https://github.com/apache/flink/pull/4525 ---

[jira] [Commented] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199702#comment-16199702 ] zhijiang commented on FLINK-7394: - [~Zentol], thank you for merging and let me know the rule. > Manage

[jira] [Assigned] (FLINK-7762) Make WikipediaEditsSourceTest a proper test

[ https://issues.apache.org/jira/browse/FLINK-7762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hai Zhou UTC+8 reassigned FLINK-7762: - Assignee: Hai Zhou UTC+8 > Make WikipediaEditsSourceTest a proper test >

[jira] [Commented] (FLINK-7669) org.apache.flink.api.common.ExecutionConfig cannot be cast to org.apache.flink.api.common.ExecutionConfig

[ https://issues.apache.org/jira/browse/FLINK-7669?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199687#comment-16199687 ] Raymond Tay commented on FLINK-7669: I tried that suggestion but it didn't work and here's what i did

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199652#comment-16199652 ] ASF GitHub Bot commented on FLINK-5486: --- Github user zhangminglei commented on the issue:

[GitHub] flink issue #4356: [FLINK-5486] Fix lacking of synchronization in BucketingS...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/4356 OKay. Thanks , Ted. Will retest again soon enough./ ---

[jira] [Commented] (FLINK-4808) Allow skipping failed checkpoints

[ https://issues.apache.org/jira/browse/FLINK-4808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199614#comment-16199614 ] Jing Fan commented on FLINK-4808: - [~StephanEwen] Do we have any update on this jira? > Allow skipping

[jira] [Commented] (FLINK-6697) Add batch multi-window support

[ https://issues.apache.org/jira/browse/FLINK-6697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199524#comment-16199524 ] ASF GitHub Bot commented on FLINK-6697: --- GitHub user fhueske opened a pull request:

[GitHub] flink pull request #4796: [FLINK-6697] [table] Add support for window.rowtim...

GitHub user fhueske opened a pull request: https://github.com/apache/flink/pull/4796 [FLINK-6697] [table] Add support for window.rowtime to batch Table API. ## What is the purpose of the change This PR adds support for the `windowAlias.rowtime` property to the batch Table

[jira] [Commented] (FLINK-7657) SQL Timestamps Converted To Wrong Type By Optimizer Causing ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-7657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199500#comment-16199500 ] ASF GitHub Bot commented on FLINK-7657: --- Github user kmurra commented on the issue:

[GitHub] flink issue #4746: [FLINK-7657] [Table] Adding logic to convert RexLiteral t...

Github user kmurra commented on the issue: https://github.com/apache/flink/pull/4746 The biggest change here is in the test cases -- I generalized the test table source to have some basic filtering logic and allow for generic datasets. I moved the Literal build logic to the

[jira] [Created] (FLINK-7801) Integrate list command into REST client

Till Rohrmann created FLINK-7801: Summary: Integrate list command into REST client Key: FLINK-7801 URL: https://issues.apache.org/jira/browse/FLINK-7801 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-6569) flink-table KafkaJsonTableSource example doesn't work

[ https://issues.apache.org/jira/browse/FLINK-6569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Haohui Mai closed FLINK-6569. - Resolution: Invalid Fix Version/s: (was: 1.4.0) > flink-table KafkaJsonTableSource example

[jira] [Commented] (FLINK-7793) SlotManager releases idle TaskManager in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-7793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199448#comment-16199448 ] ASF GitHub Bot commented on FLINK-7793: --- GitHub user tillrohrmann opened a pull request:

[GitHub] flink pull request #4795: [FLINK-7793] [flip6] Defer slot release to Resourc...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4795 [FLINK-7793] [flip6] Defer slot release to ResourceManager ## What is the purpose of the change This commit changes the SlotManager behaviour such that upon a TaskManager timeout

[jira] [Created] (FLINK-7800) Enable window joins without equi-join predicates

Fabian Hueske created FLINK-7800: Summary: Enable window joins without equi-join predicates Key: FLINK-7800 URL: https://issues.apache.org/jira/browse/FLINK-7800 Project: Flink Issue Type:

[jira] [Created] (FLINK-7799) Improve performance of windowed joins

Fabian Hueske created FLINK-7799: Summary: Improve performance of windowed joins Key: FLINK-7799 URL: https://issues.apache.org/jira/browse/FLINK-7799 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-7798) Add support for windowed joins to Table API

Fabian Hueske created FLINK-7798: Summary: Add support for windowed joins to Table API Key: FLINK-7798 URL: https://issues.apache.org/jira/browse/FLINK-7798 Project: Flink Issue Type:

[jira] [Updated] (FLINK-5725) Support windowed JOIN between two streaming tables

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5725: - Summary: Support windowed JOIN between two streaming tables (was: Support windowed JOIN between

[jira] [Created] (FLINK-7797) Add support for windowed outer joins for streaming tables

Fabian Hueske created FLINK-7797: Summary: Add support for windowed outer joins for streaming tables Key: FLINK-7797 URL: https://issues.apache.org/jira/browse/FLINK-7797 Project: Flink

[jira] [Updated] (FLINK-5725) Support windowed JOIN between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-5725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske updated FLINK-5725: - Summary: Support windowed JOIN between two streams in the SQL API (was: Support JOIN between two

[jira] [Closed] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7410. Resolution: Implemented Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7491. Resolution: Fixed Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-7776) do not emit duplicated records in group aggregation

[ https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-7776. Resolution: Fixed Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Closed] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6233. Resolution: Fixed Fix Version/s: 1.4.0 Implemented for 1.4.0 with

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199358#comment-16199358 ] ASF GitHub Bot commented on FLINK-6233: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7776) do not emit duplicated records in group aggregation

[ https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199359#comment-16199359 ] ASF GitHub Bot commented on FLINK-7776: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199360#comment-16199360 ] ASF GitHub Bot commented on FLINK-7491: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199361#comment-16199361 ] ASF GitHub Bot commented on FLINK-7410: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInf...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4585 ---

[GitHub] flink pull request #4624: [FLINK-7410] [table] Use toString method to displa...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4624 ---

[GitHub] flink pull request #4785: [FLINK-7776][TableAPI & SQL] do not emit duplicate...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4785 ---

[GitHub] flink pull request #4625: [FLINK-6233] [table] Support time-bounded stream i...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4625 ---

[jira] [Resolved] (FLINK-7704) Port JobPlanHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7704. -- Resolution: Done Done via 9829ca00dff201879724847b498fe0432219cb53 > Port JobPlanHandler to

[jira] [Commented] (FLINK-7704) Port JobPlanHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199343#comment-16199343 ] ASF GitHub Bot commented on FLINK-7704: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4768: [FLINK-7704][flip6] Add JobPlanHandler for new Res...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4768 ---

[jira] [Created] (FLINK-7796) RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry

Ted Yu created FLINK-7796: - Summary: RocksDBKeyedStateBackend#RocksDBFullSnapshotOperation should close snapshotCloseableRegistry Key: FLINK-7796 URL: https://issues.apache.org/jira/browse/FLINK-7796

[jira] [Commented] (FLINK-7750) Strange behaviour in savepoints

[ https://issues.apache.org/jira/browse/FLINK-7750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199262#comment-16199262 ] Razvan commented on FLINK-7750: --- [~aljoscha] Many thanks for clarifying this. Is there a way to update

[jira] [Commented] (FLINK-5486) Lack of synchronization in BucketingSink#handleRestoredBucketState()

[ https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199255#comment-16199255 ] ASF GitHub Bot commented on FLINK-5486: --- Github user tedyu commented on the issue:

[GitHub] flink issue #4356: [FLINK-5486] Fix lacking of synchronization in BucketingS...

Github user tedyu commented on the issue: https://github.com/apache/flink/pull/4356 retest this please ---

[jira] [Created] (FLINK-7795) Utilize error-prone to discover common coding mistakes

Ted Yu created FLINK-7795: - Summary: Utilize error-prone to discover common coding mistakes Key: FLINK-7795 URL: https://issues.apache.org/jira/browse/FLINK-7795 Project: Flink Issue Type:

[GitHub] flink pull request #4794: [build][minor] Add missing licenses

GitHub user yew1eb opened a pull request: https://github.com/apache/flink/pull/4794 [build][minor] Add missing licenses You can merge this pull request into a Git repository by running: $ git pull https://github.com/yew1eb/flink add_missing_licenses Alternatively you can

[GitHub] flink issue #4790: [FLINK-7764] [kafka] Enable the operator settings for Fli...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/4790 cc @aljoscha and @pnowojski I think there is some work for Flink 1.4 to make the Kafka 0.10 sink a regular sink function, so that the code that constructs the sink transformation is not

[jira] [Commented] (FLINK-7764) FlinkKafkaProducer010 does not accept name, uid, or parallelism

[ https://issues.apache.org/jira/browse/FLINK-7764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199129#comment-16199129 ] ASF GitHub Bot commented on FLINK-7764: --- Github user StephanEwen commented on the issue:

[jira] [Commented] (FLINK-6225) Support Row Stream for CassandraSink

[ https://issues.apache.org/jira/browse/FLINK-6225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199094#comment-16199094 ] ASF GitHub Bot commented on FLINK-6225: --- Github user PangZhi commented on the issue:

[GitHub] flink issue #3748: [FLINK-6225] [Cassandra Connector] add CassandraTableSink

Github user PangZhi commented on the issue: https://github.com/apache/flink/pull/3748 @zentol Do you mind taking another look. ---

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16199070#comment-16199070 ] Ryan Hobbs commented on FLINK-7737: --- In the case of hflush() it is simply flushing the buffer but there

[jira] [Commented] (FLINK-6233) Support rowtime inner equi-join between two streams in the SQL API

[ https://issues.apache.org/jira/browse/FLINK-6233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198954#comment-16198954 ] ASF GitHub Bot commented on FLINK-6233: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7776) do not emit duplicated records in group aggregation

[ https://issues.apache.org/jira/browse/FLINK-7776?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198952#comment-16198952 ] ASF GitHub Bot commented on FLINK-7776: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4625: [FLINK-6233] [table] Support time-bounded stream inner jo...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4625 Merging ---

[jira] [Commented] (FLINK-7491) Support COLLECT Aggregate function in Flink SQL

[ https://issues.apache.org/jira/browse/FLINK-7491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198950#comment-16198950 ] ASF GitHub Bot commented on FLINK-7491: --- Github user fhueske commented on the issue:

[jira] [Commented] (FLINK-7410) Use toString method to display operator names for UserDefinedFunction

[ https://issues.apache.org/jira/browse/FLINK-7410?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198948#comment-16198948 ] ASF GitHub Bot commented on FLINK-7410: --- Github user fhueske commented on the issue:

[GitHub] flink issue #4785: [FLINK-7776][TableAPI & SQL] do not emit duplicated recor...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4785 Merging ---

[GitHub] flink issue #4585: [FLINK-7491] [Table API & SQL] add MultiSetTypeInfo; add ...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4585 Merging ---

[GitHub] flink issue #4624: [FLINK-7410] [table] Use toString method to display opera...

Github user fhueske commented on the issue: https://github.com/apache/flink/pull/4624 Merging ---

[jira] [Created] (FLINK-7794) Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html

Paul Wu created FLINK-7794: -- Summary: Link Broken in -- https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/connectors/index.html Key: FLINK-7794 URL: https://issues.apache.org/jira/browse/FLINK-7794

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198898#comment-16198898 ] Vijay Srinivasaraghavan commented on FLINK-7737: I believe hflush() routes the data to DN

[jira] [Created] (FLINK-7793) SlotManager releases idle TaskManager in standalone mode

Till Rohrmann created FLINK-7793: Summary: SlotManager releases idle TaskManager in standalone mode Key: FLINK-7793 URL: https://issues.apache.org/jira/browse/FLINK-7793 Project: Flink Issue

[jira] [Commented] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198841#comment-16198841 ] ASF GitHub Bot commented on FLINK-7709: --- Github user tillrohrmann closed the pull request at:

[GitHub] flink pull request #4763: [FLINK-7709] Add CheckpointStatisticDetailsHandler...

Github user tillrohrmann closed the pull request at: https://github.com/apache/flink/pull/4763 ---

[jira] [Resolved] (FLINK-7709) Port CheckpointStatsDetailsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7709. -- Resolution: Done Added via 0a286d0ff98afa68034daff4634f526eaaf97897 > Port

[GitHub] flink pull request #4793: [FLINK-7653] Properly implement Dispatcher#request...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/4793 [FLINK-7653] Properly implement Dispatcher#requestClusterOverview ## What is the purpose of the change This commit implements the ClusterOverview generation on the Dispatcher. In

[jira] [Commented] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198819#comment-16198819 ] ASF GitHub Bot commented on FLINK-7653: --- GitHub user tillrohrmann opened a pull request:

[jira] [Commented] (FLINK-7652) Port CurrentJobIdsHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198803#comment-16198803 ] ASF GitHub Bot commented on FLINK-7652: --- Github user tillrohrmann commented on the issue:

[GitHub] flink issue #4734: [FLINK-7652] [flip6] Port CurrentJobIdsHandler to new RES...

Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/4734 I agree with @zentol. Moreover, I would like to change `MultipleJobsDetails` to not split the job details into running and finished. Just a collection of `JobDetails`. ---

[jira] [Commented] (FLINK-7790) Unresolved query parameters are not omitted from request

[ https://issues.apache.org/jira/browse/FLINK-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198797#comment-16198797 ] ASF GitHub Bot commented on FLINK-7790: --- Github user zentol closed the pull request at:

[GitHub] flink pull request #4788: [FLINK-7790] [REST] Unresolved query params not ad...

Github user zentol closed the pull request at: https://github.com/apache/flink/pull/4788 ---

[jira] [Closed] (FLINK-7790) Unresolved query parameters are not omitted from request

[ https://issues.apache.org/jira/browse/FLINK-7790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7790. --- Resolution: Fixed 1.4: 6b3fdc288587fe0982f2ffa2e476e0fd3cd61188 > Unresolved query

[jira] [Commented] (FLINK-7378) Create a fix size (non rebalancing) buffer pool type for the floating buffers

[ https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198784#comment-16198784 ] ASF GitHub Bot commented on FLINK-7378: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198781#comment-16198781 ] Chesnay Schepler commented on FLINK-7394: - 1.4: 1f4bdf44b6fa4fd071d9a45aca7dd6b7a4d3090d > Manage

[jira] [Commented] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198785#comment-16198785 ] ASF GitHub Bot commented on FLINK-7699: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198787#comment-16198787 ] Chesnay Schepler commented on FLINK-7394: - [~zjwang] Please leave it to the committer to close the

[GitHub] flink pull request #4485: [FLINK-7378][core]Create a fix size (non rebalanci...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4485 ---

[jira] [Commented] (FLINK-7378) Create a fix size (non rebalancing) buffer pool type for the floating buffers

[ https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198780#comment-16198780 ] Chesnay Schepler commented on FLINK-7378: - 1.4: 450d9df9e96718575ab2979f256f99be4d699636 > Create

[jira] [Commented] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198783#comment-16198783 ] ASF GitHub Bot commented on FLINK-7394: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #4735: [FLINK-7699][core] Define the BufferListener inter...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4735 ---

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4499 ---

[jira] [Reopened] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reopened FLINK-7699: - > Define the BufferListener interface to replace EventListener in BufferProvider >

[jira] [Closed] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-7699. --- Resolution: Fixed 1.4: 331b7778e4533cd140ffe6e3edaa79994122a592 > Define the BufferListener

[jira] [Commented] (FLINK-7792) CliFrontend tests suppress logging

[ https://issues.apache.org/jira/browse/FLINK-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198747#comment-16198747 ] ASF GitHub Bot commented on FLINK-7792: --- GitHub user zentol opened a pull request:

[GitHub] flink pull request #4792: [FLINK-7792] [tests][client] Only suppress stdout ...

GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/4792 [FLINK-7792] [tests][client] Only suppress stdout for CLI tests ## What is the purpose of the change This PR modifies the CliFrontendTestUtils to only suppress stdout. Previously we were

[jira] [Closed] (FLINK-7699) Define the BufferListener interface to replace EventListener in BufferProvider

[ https://issues.apache.org/jira/browse/FLINK-7699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-7699. --- Resolution: Fixed > Define the BufferListener interface to replace EventListener in BufferProvider >

[jira] [Updated] (FLINK-7792) CliFrontend tests suppress logging

[ https://issues.apache.org/jira/browse/FLINK-7792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7792: Priority: Trivial (was: Major) > CliFrontend tests suppress logging >

[jira] [Created] (FLINK-7792) CliFrontend tests suppress logging

Chesnay Schepler created FLINK-7792: --- Summary: CliFrontend tests suppress logging Key: FLINK-7792 URL: https://issues.apache.org/jira/browse/FLINK-7792 Project: Flink Issue Type: Bug

[GitHub] flink pull request #4791: [hotfix] [Javadoc] Fix typos

GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/4791 [hotfix] [Javadoc] Fix typos Fix typos in Javadoc for classes: - `org.apache.flink.api.java.typeutils.InputTypeConfigurable` - `org.apache.flink.core.fs.FileSystem` You can merge this pull

[jira] [Closed] (FLINK-7394) Manage exclusive buffers in RemoteInputChannel

[ https://issues.apache.org/jira/browse/FLINK-7394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-7394. --- Resolution: Fixed > Manage exclusive buffers in RemoteInputChannel >

[jira] [Closed] (FLINK-7378) Create a fix size (non rebalancing) buffer pool type for the floating buffers

[ https://issues.apache.org/jira/browse/FLINK-7378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] zhijiang closed FLINK-7378. --- Resolution: Fixed > Create a fix size (non rebalancing) buffer pool type for the floating buffers >

[jira] [Commented] (FLINK-7704) Port JobPlanHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198732#comment-16198732 ] ASF GitHub Bot commented on FLINK-7704: --- Github user yew1eb commented on the issue:

[GitHub] flink issue #4768: [FLINK-7704][flip6] Add JobPlanHandler for new RestServer...

Github user yew1eb commented on the issue: https://github.com/apache/flink/pull/4768 CC @tillrohrmann ---

[jira] [Commented] (FLINK-1268) FileOutputFormat with overwrite does not clear local output directories

[ https://issues.apache.org/jira/browse/FLINK-1268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198727#comment-16198727 ] Gabor Gevay commented on FLINK-1268: This issue just happened to me. I ran my job locally with

[jira] [Assigned] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-7653: Assignee: Till Rohrmann > Properly implement DispatcherGateway methods on the Dispatcher >

[jira] [Updated] (FLINK-7653) Properly implement DispatcherGateway methods on the Dispatcher

[ https://issues.apache.org/jira/browse/FLINK-7653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-7653: - Affects Version/s: 1.4.0 > Properly implement DispatcherGateway methods on the Dispatcher >

[jira] [Commented] (FLINK-7737) On HCFS systems, FSDataOutputStream does not issue hsync only hflush which leads to data loss

[ https://issues.apache.org/jira/browse/FLINK-7737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16198722#comment-16198722 ] Stephan Ewen commented on FLINK-7737: - Or, let me rephrase the question: Is the data replicated to the

  1   2   3   >