[jira] [Updated] (FLINK-10766) Add a link to flink-china.org in Flink website

[ https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10766: --- Labels: pull-request-available (was: ) > Add a link to flink-china.org in Flink website >

[jira] [Commented] (FLINK-10766) Add a link to flink-china.org in Flink website

[ https://issues.apache.org/jira/browse/FLINK-10766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674756#comment-16674756 ] ASF GitHub Bot commented on FLINK-10766: wuchong opened a new pull request #134: [FLINK-10766]

[jira] [Commented] (FLINK-10704) Fix sql client end to end test failure

[ https://issues.apache.org/jira/browse/FLINK-10704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674726#comment-16674726 ] vinoyang commented on FLINK-10704: -- [~twalthr] After our last communication, my local test has been

[jira] [Commented] (FLINK-10768) Move external catalog related code from TableEnvironment to CatalogManager

[ https://issues.apache.org/jira/browse/FLINK-10768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674698#comment-16674698 ] ASF GitHub Bot commented on FLINK-10768: bowenli86 commented on issue #7011: [FLINK-10768][Table

[jira] [Commented] (FLINK-10769) port InMemoryExternalCatalog to java

[ https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674696#comment-16674696 ] ASF GitHub Bot commented on FLINK-10769: bowenli86 commented on issue #7012: [FLINK-10769][Table

[GitHub] bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager

bowenli86 commented on issue #7011: [FLINK-10768][Table & SQL] Move external catalog related code from TableEnvironment to CatalogManager URL: https://github.com/apache/flink/pull/7011#issuecomment-435762762 @twalthr @fhueske @xuefuz Can you please take a look?

[jira] [Commented] (FLINK-10769) port InMemoryExternalCatalog to java

[ https://issues.apache.org/jira/browse/FLINK-10769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674697#comment-16674697 ] ASF GitHub Bot commented on FLINK-10769: bowenli86 edited a comment on issue #7012:

[GitHub] bowenli86 edited a comment on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java

bowenli86 edited a comment on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java URL: https://github.com/apache/flink/pull/7012#issuecomment-435762643 @twalthr @fhueske @xuefuz Can you please take a look?

[GitHub] bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java

bowenli86 commented on issue #7012: [FLINK-10769][Table & SQL] port InMemoryExternalCatalog to java URL: https://github.com/apache/flink/pull/7012#issuecomment-435762643 @twalthr @fhueske Can you please take a look? This is

[jira] [Commented] (FLINK-10168) Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time

[ https://issues.apache.org/jira/browse/FLINK-10168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674686#comment-16674686 ] ASF GitHub Bot commented on FLINK-10168: bowenli86 commented on issue #6979: [FLINK-10168] Add

[GitHub] bowenli86 commented on issue #6979: [FLINK-10168] Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time

bowenli86 commented on issue #6979: [FLINK-10168] Add FileFilter interface and FileModTimeFilter which sets a read start position for files by modification time URL: https://github.com/apache/flink/pull/6979#issuecomment-435760477 @kl0u @fhueske Can you take a look?

[jira] [Updated] (FLINK-10392) Remove legacy mode

[ https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10392: - Fix Version/s: (was: 1.7.0) 1.8.0 > Remove legacy mode > -- > >

[jira] [Updated] (FLINK-10392) Remove legacy mode

[ https://issues.apache.org/jira/browse/FLINK-10392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TisonKun updated FLINK-10392: - Affects Version/s: (was: 1.7.0) > Remove legacy mode > -- > > Key:

[jira] [Commented] (FLINK-10461) Speed up download file procedure when restore

[ https://issues.apache.org/jira/browse/FLINK-10461?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674635#comment-16674635 ] ASF GitHub Bot commented on FLINK-10461: klion26 commented on issue #6777: [FLINK-10461] [State

[GitHub] klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS

klion26 commented on issue #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#issuecomment-435747811 Hi, @azagrebin , I've just addressed all comments, please help to review this when you have

[jira] [Comment Edited] (FLINK-9050) Expose operator IO counter metrics

[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674632#comment-16674632 ] lining edited comment on FLINK-9050 at 11/5/18 3:47 AM: [~Zentol] Whether too

[jira] [Commented] (FLINK-9050) Expose operator IO counter metrics

[ https://issues.apache.org/jira/browse/FLINK-9050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674632#comment-16674632 ] lining commented on FLINK-9050: --- [~Zentol] if too many operators will cause jm oom. > Expose operator IO

[jira] [Commented] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError

[ https://issues.apache.org/jira/browse/FLINK-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674631#comment-16674631 ] ASF GitHub Bot commented on FLINK-8897: --- hequn8128 commented on issue #6987: [FLINK-8897] [table]

[GitHub] hequn8128 commented on issue #6987: [FLINK-8897] [table] Fix rowtime materialization issues for filters and joins

hequn8128 commented on issue #6987: [FLINK-8897] [table] Fix rowtime materialization issues for filters and joins URL: https://github.com/apache/flink/pull/6987#issuecomment-435747112 Hi, @twalthr A neat fix! LGTM. And thanks for adding the logic that throw an exception in

[jira] [Commented] (FLINK-8897) Rowtime materialization causes "mismatched type" AssertionError

[ https://issues.apache.org/jira/browse/FLINK-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674623#comment-16674623 ] ASF GitHub Bot commented on FLINK-8897: --- hequn8128 commented on a change in pull request #6987:

[GitHub] hequn8128 commented on a change in pull request #6987: [FLINK-8897] [table] Fix rowtime materialization issues for filters and joins

hequn8128 commented on a change in pull request #6987: [FLINK-8897] [table] Fix rowtime materialization issues for filters and joins URL: https://github.com/apache/flink/pull/6987#discussion_r230626371 ## File path:

[jira] [Issue Comment Deleted] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-7286: -- Comment: was deleted (was: Ok， thanks. ) > Flink Dashboard fails to display bytes/records received by sources

[jira] [Issue Comment Deleted] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-7286: -- Comment: was deleted (was: Hi, [~aljoscha]. I am doing this now, can assign this to me.) > Flink Dashboard

[jira] [Commented] (FLINK-10703) Race condition in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-10703?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674615#comment-16674615 ] Shimin Yang commented on FLINK-10703: - Thanks [~till.rohrmann]. I didn't notice the runAsync was

[jira] [Closed] (FLINK-10703) Race condition in YarnResourceManager

[ https://issues.apache.org/jira/browse/FLINK-10703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shimin Yang closed FLINK-10703. --- Resolution: Not A Problem > Race condition in YarnResourceManager >

[jira] [Updated] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10774: --- Labels: pull-request-available (was: ) > connection leak when partition discovery is

[jira] [Commented] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674606#comment-16674606 ] ASF GitHub Bot commented on FLINK-10774: stevenzwu opened a new pull request #7020:

[GitHub] stevenzwu opened a new pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an…

stevenzwu opened a new pull request #7020: [FLINK-10774] [Kafka] connection leak when partition discovery is disabled an… URL: https://github.com/apache/flink/pull/7020 …d open throws exception This is an automated

[jira] [Commented] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674503#comment-16674503 ] Chesnay Schepler commented on FLINK-10772: -- Please also create a backport for 1.6. >

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10772: - Affects Version/s: 1.8.0 > create_binary_release.sh is broken >

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10772: - Affects Version/s: (was: 1.8.0) > create_binary_release.sh is broken >

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-10772: - Affects Version/s: 1.6.2 > create_binary_release.sh is broken >

[jira] [Commented] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674502#comment-16674502 ] ASF GitHub Bot commented on FLINK-10772: zentol commented on issue #7016: [FLINK-10772][release]

[GitHub] zentol commented on issue #7016: [FLINK-10772][release] Fix create_binary_release.sh

zentol commented on issue #7016: [FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7016#issuecomment-435704321 Oh it probably works if you first deploy the artifacts since that includes the `install` phase and doesn't skip anything.

[jira] [Commented] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674501#comment-16674501 ] ASF GitHub Bot commented on FLINK-10772: zentol commented on issue #7016: [FLINK-10772][release]

[GitHub] zentol commented on issue #7016: [FLINK-10772][release] Fix create_binary_release.sh

zentol commented on issue #7016: [FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7016#issuecomment-435704175 There's something we're missing here; this issue should've also affected the 1.6.X releases.

[GitHub] tillrohrmann opened a new pull request #7019: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test

tillrohrmann opened a new pull request #7019: [BP-1.7][FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7019 Backport of #7018 for `release-1.7` This is an

[jira] [Updated] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

[ https://issues.apache.org/jira/browse/FLINK-10773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10773: --- Labels: pull-request-available test-stability (was: test-stability) > Resume externalized

[jira] [Commented] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

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

[GitHub] tillrohrmann opened a new pull request #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test

tillrohrmann opened a new pull request #7018: [FLINK-10773] Harden resume externalized checkpoint end-to-end test URL: https://github.com/apache/flink/pull/7018 ## What is the purpose of the change Ignore the 'Artificial Failure' exceptions and rename

[jira] [Commented] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

[ https://issues.apache.org/jira/browse/FLINK-10774?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674471#comment-16674471 ] Steven Zhen Wu commented on FLINK-10774: [~srichter]  FYI. I will submit a patch soon >

[jira] [Created] (FLINK-10774) connection leak when partition discovery is disabled and open throws exception

Steven Zhen Wu created FLINK-10774: -- Summary: connection leak when partition discovery is disabled and open throws exception Key: FLINK-10774 URL: https://issues.apache.org/jira/browse/FLINK-10774

[jira] [Created] (FLINK-10773) Resume externalized checkpoint end-to-end test fails

Till Rohrmann created FLINK-10773: - Summary: Resume externalized checkpoint end-to-end test fails Key: FLINK-10773 URL: https://issues.apache.org/jira/browse/FLINK-10773 Project: Flink Issue

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-10772: -- Description: The {{create_binary_release.sh}} is broken because it calls a script which does

[GitHub] tillrohrmann opened a new pull request #7017: [BP-1.7][FLINK-10772][release] Fix create_binary_release.sh

tillrohrmann opened a new pull request #7017: [BP-1.7][FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7017 Backport of #7016 to `release-1.7`. This is an automated message from

[jira] [Updated] (FLINK-10772) create_binary_release.sh is broken

[ https://issues.apache.org/jira/browse/FLINK-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10772: --- Labels: pull-request-available (was: ) > create_binary_release.sh is broken >

[jira] [Commented] (FLINK-10772) create_binary_release.sh is broken

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

[GitHub] tillrohrmann opened a new pull request #7016: [FLINK-10772][release] Fix create_binary_release.sh

tillrohrmann opened a new pull request #7016: [FLINK-10772][release] Fix create_binary_release.sh URL: https://github.com/apache/flink/pull/7016 ## What is the purpose of the change Remove the unnecessary call to change_scala_version.sh and remove the -Dmaven.test.skip=true

[jira] [Created] (FLINK-10772) create_binary_release.sh is broken

Till Rohrmann created FLINK-10772: - Summary: create_binary_release.sh is broken Key: FLINK-10772 URL: https://issues.apache.org/jira/browse/FLINK-10772 Project: Flink Issue Type: Bug

[GitHub] wangkuiyi opened a new pull request #7015: Add the -p option to nc

wangkuiyi opened a new pull request #7015: Add the -p option to nc URL: https://github.com/apache/flink/pull/7015 When I run the [quick start](https://ci.apache.org/projects/flink/flink-docs-release-1.6/quickstart/setup_quickstart.html) tutorial in Docker containers (`docker run flink`),

[jira] [Closed] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-10357. Resolution: Fixed > Streaming File Sink end-to-end test failed with mismatch >

[jira] [Comment Edited] (FLINK-10357) Streaming File Sink end-to-end test failed with mismatch

[ https://issues.apache.org/jira/browse/FLINK-10357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668762#comment-16668762 ] Gary Yao edited comment on FLINK-10357 at 11/4/18 4:49 PM: --- 1.6:

[GitHub] GJL closed pull request #6999: [BP-1.6][FLINK-10357][tests] Improve StreamingFileSink E2E test stability.

GJL closed pull request #6999: [BP-1.6][FLINK-10357][tests] Improve StreamingFileSink E2E test stability. URL: https://github.com/apache/flink/pull/6999 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-10570) State grows unbounded when "within" constraint not applied

[ https://issues.apache.org/jira/browse/FLINK-10570?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674424#comment-16674424 ] Thomas Wozniakowski commented on FLINK-10570: - Hi [~dawidwys], I notice this is scheduled

[jira] [Created] (FLINK-10771) Replace hard code of job graph file path with config option for FileJobGraphRetriever

vinoyang created FLINK-10771: Summary: Replace hard code of job graph file path with config option for FileJobGraphRetriever Key: FLINK-10771 URL: https://issues.apache.org/jira/browse/FLINK-10771

[jira] [Commented] (FLINK-10571) Remove support for topologies

[ https://issues.apache.org/jira/browse/FLINK-10571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16674349#comment-16674349 ] ASF GitHub Bot commented on FLINK-10571: TisonKun commented on issue #6880: [FLINK-10571][storm]

[GitHub] TisonKun commented on issue #6880: [FLINK-10571][storm] Remove topology support

TisonKun commented on issue #6880: [FLINK-10571][storm] Remove topology support URL: https://github.com/apache/flink/pull/6880#issuecomment-435652430 The process of this removal follows the discussion on the ML and given that release-1.7.0 branch was cut, we can restart to process this