[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488530#comment-16488530 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190482258 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * Li

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488529#comment-16488529 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190481987 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java --- @@ -0,0 +1,235 @@ +/* +

[GitHub] flink pull request #6058: [FLINK-9415] Remove reference to StreamingMultiple...

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

[jira] [Commented] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

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

[jira] [Resolved] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

[ https://issues.apache.org/jira/browse/FLINK-9415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-9415. Resolution: Fixed Fix Version/s: 1.5.1 1.6.0 Merged. 1.6.

[jira] [Updated] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

[ https://issues.apache.org/jira/browse/FLINK-9430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen updated FLINK-9430: -- Description: We want to add a SQL UDF to access specific element in a JSON string using JSON path. Howe

[jira] [Created] (FLINK-9430) Support Casting of Object to Primitive types for Flink SQL UDF

Shuyi Chen created FLINK-9430: - Summary: Support Casting of Object to Primitive types for Flink SQL UDF Key: FLINK-9430 URL: https://issues.apache.org/jira/browse/FLINK-9430 Project: Flink Issue

[jira] [Comment Edited] (FLINK-9091) Failure while enforcing releasability in building flink-json module

[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488431#comment-16488431 ] Chesnay Schepler edited comment on FLINK-9091 at 5/24/18 5:18 AM: --

[jira] [Commented] (FLINK-9091) Failure while enforcing releasability in building flink-json module

[ https://issues.apache.org/jira/browse/FLINK-9091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488431#comment-16488431 ] Chesnay Schepler commented on FLINK-9091: - Another option would be to disable the

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488417#comment-16488417 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190463723 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java --- @@ -0,0 +1,235 @@ +/* + * Li

[jira] [Commented] (FLINK-8390) Refactor Hadoop kerberos integration test code

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

[jira] [Commented] (FLINK-8390) Refactor Hadoop kerberos integration test code

[ https://issues.apache.org/jira/browse/FLINK-8390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488407#comment-16488407 ] ASF GitHub Bot commented on FLINK-8390: --- Github user suez1224 closed the pull reques

[GitHub] flink pull request #5306: [FLINK-8390][security]remove unused integration te...

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

[GitHub] flink issue #5306: [FLINK-8390][security]remove unused integration test code

Github user suez1224 commented on the issue: https://github.com/apache/flink/pull/5306 @zentol , you are right, https://issues.apache.org/jira/browse/FLINK-8286 already did the removal. ---

[jira] [Commented] (FLINK-8790) Improve performance for recovery from incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-8790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488360#comment-16488360 ] ASF GitHub Bot commented on FLINK-8790: --- Github user sihuazhou commented on the issu

[GitHub] flink issue #5582: [FLINK-8790][State] Improve performance for recovery from...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5582 Unfortunately, after confirming with RocksDB, the `deleteRange()` is still an experimental feature, it may have impact on read performance currently(event thought we could use the ReadOption to red

[jira] [Commented] (FLINK-9425) Make release scripts compliant with ASF release policy

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

[GitHub] flink issue #6061: [FLINK-9425] Make release scripts compliant with ASF rele...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/6061 +1, thanks for the compliance updates. LGTM. ---

[GitHub] flink issue #6058: [FLINK-9415] Remove reference to StreamingMultipleProgram...

Github user tzulitai commented on the issue: https://github.com/apache/flink/pull/6058 +1, LGTM Merging this .. ---

[jira] [Commented] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

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

[jira] [Commented] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488314#comment-16488314 ] mingleizhang commented on FLINK-9429: - Hi, [~till.rohrmann]. Have you build flink agai

[jira] [Comment Edited] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488298#comment-16488298 ] Hequn Cheng edited comment on FLINK-9422 at 5/24/18 1:54 AM: -

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488298#comment-16488298 ] Hequn Cheng commented on FLINK-9422: Hi, I agree that we need a dedicated operator. Bu

[jira] [Commented] (FLINK-8985) End-to-end test: CLI

[ https://issues.apache.org/jira/browse/FLINK-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488225#comment-16488225 ] ASF GitHub Bot commented on FLINK-8985: --- Github user walterddr commented on a diff i

[GitHub] flink pull request #5863: [FLINK-8985][e2etest] initial support for End-to-e...

Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5863#discussion_r190433925 --- Diff: flink-end-to-end-tests/test-scripts/test_cli_api.sh --- @@ -0,0 +1,155 @@ +#!/usr/bin/env bash +#

[jira] [Updated] (FLINK-8622) flink-mesos: High memory usage of scheduler + job manager. GC never kicks in.

[ https://issues.apache.org/jira/browse/FLINK-8622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eron Wright updated FLINK-8622: Fix Version/s: (was: 1.5.0) > flink-mesos: High memory usage of scheduler + job manager. GC neve

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488212#comment-16488212 ] vinoyang commented on FLINK-9421: - [~till.rohrmann] I have releases the  assignee, please

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488213#comment-16488213 ] Keda Ruan commented on FLINK-7477: -- Hey, just curious whether this commit will be merged

[jira] [Assigned] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-9421: --- Assignee: (was: vinoyang) > RunningJobsRegistry entries are not cleaned up after job termination

[jira] [Commented] (FLINK-9415) Remove reference to StreamingMultipleProgramsTestBase in docs

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

[GitHub] flink issue #6058: [FLINK-9415] Remove reference to StreamingMultipleProgram...

Github user tweise commented on the issue: https://github.com/apache/flink/pull/6058 @tzulitai PTAL ---

[jira] [Commented] (FLINK-9421) RunningJobsRegistry entries are not cleaned up after job termination

[ https://issues.apache.org/jira/browse/FLINK-9421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16488085#comment-16488085 ] Till Rohrmann commented on FLINK-9421: -- Sorry [~yanghua], I actually have a fix ready

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487968#comment-16487968 ] Rong Rong commented on FLINK-9422: -- +1 on "can apply windowed aggregates on the result".

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487863#comment-16487863 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on a diff in t

[GitHub] flink pull request #6043: [FLINK-7386] evolve RequestIndexer API to make it ...

Github user cjolif commented on a diff in the pull request: https://github.com/apache/flink/pull/6043#discussion_r190364900 --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java --- @@ -2

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487833#comment-16487833 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on a diff in t

[GitHub] flink pull request #6043: [FLINK-7386] evolve RequestIndexer API to make it ...

Github user cjolif commented on a diff in the pull request: https://github.com/apache/flink/pull/6043#discussion_r190359388 --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/BulkProcessorIndexer.java ---

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487834#comment-16487834 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on a diff in t

[GitHub] flink pull request #6043: [FLINK-7386] evolve RequestIndexer API to make it ...

Github user cjolif commented on a diff in the pull request: https://github.com/apache/flink/pull/6043#discussion_r190359413 --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java --- @@ -2

[GitHub] flink pull request #6043: [FLINK-7386] evolve RequestIndexer API to make it ...

Github user cjolif commented on a diff in the pull request: https://github.com/apache/flink/pull/6043#discussion_r190359344 --- Diff: flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/RequestIndexer.java --- @@ -2

[jira] [Commented] (FLINK-7386) Flink Elasticsearch 5 connector is not compatible with Elasticsearch 5.2+ client

[ https://issues.apache.org/jira/browse/FLINK-7386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487832#comment-16487832 ] ASF GitHub Bot commented on FLINK-7386: --- Github user cjolif commented on a diff in t

[jira] [Commented] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier

[ https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487750#comment-16487750 ] ASF GitHub Bot commented on FLINK-9428: --- Github user bowenli86 commented on a diff i

[GitHub] flink pull request #6066: [FLINK-9428] [checkpointing] Allow operators to fl...

Github user bowenli86 commented on a diff in the pull request: https://github.com/apache/flink/pull/6066#discussion_r190342404 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java --- @@ -93,6 +93,20 @@ // state snapsho

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487585#comment-16487585 ] Fabian Hueske commented on FLINK-9422: -- I think a dedicated operator would be good, e

[jira] [Commented] (FLINK-9422) Dedicated operator for UNION on streaming tables with time attributes

[ https://issues.apache.org/jira/browse/FLINK-9422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487575#comment-16487575 ] Hequn Cheng commented on FLINK-9422: Hi [~fhueske] [~RuidongLi] , I am not sure if we

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487565#comment-16487565 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190311650 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[jira] [Closed] (FLINK-9419) UNION should not be treated as retraction producing operator

[ https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-9419. Resolution: Duplicate Duplicate of FLINK-8594 > UNION should not be treated as retraction producing

[jira] [Commented] (FLINK-9419) UNION should not be treated as retraction producing operator

[ https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487539#comment-16487539 ] Fabian Hueske commented on FLINK-9419: -- Yes, you are right [~hequn8128]. This is a du

[jira] [Commented] (FLINK-9419) UNION should not be treated as retraction producing operator

[ https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487523#comment-16487523 ] Hequn Cheng commented on FLINK-9419: Hi, [~fhueske], same problem as [FLINK-8566|http

[jira] [Assigned] (FLINK-9419) UNION should not be treated as retraction producing operator

[ https://issues.apache.org/jira/browse/FLINK-9419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-9419: -- Assignee: Hequn Cheng > UNION should not be treated as retraction producing operator >

[jira] [Assigned] (FLINK-9429) Quickstart E2E not working locally

[ https://issues.apache.org/jira/browse/FLINK-9429?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mingleizhang reassigned FLINK-9429: --- Assignee: mingleizhang > Quickstart E2E not working locally > ---

[jira] [Commented] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier

[ https://issues.apache.org/jira/browse/FLINK-9428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487507#comment-16487507 ] ASF GitHub Bot commented on FLINK-9428: --- GitHub user StephanEwen opened a pull reque

[GitHub] flink pull request #6066: [FLINK-9428] [checkpointing] Allow operators to fl...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/6066 [FLINK-9428] [checkpointing] Allow operators to flush data on checkpoint pre-barrier ## What is the purpose of the change Some operators maintain some small transient state that may be

[jira] [Commented] (FLINK-9420) Add tests for SQL IN sub-query operator in streaming

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

[GitHub] flink pull request #6065: [FLINK-9420][TableAPI & SQL] Add tests for SQL IN ...

GitHub user Xpray opened a pull request: https://github.com/apache/flink/pull/6065 [FLINK-9420][TableAPI & SQL] Add tests for SQL IN sub-query operator in streaming ## What is the purpose of the change Add tests for SQL IN sub-query operator in streaming ## Br

[jira] [Commented] (FLINK-8518) Support DOW, EPOCH, DECADE for EXTRACT

[ https://issues.apache.org/jira/browse/FLINK-8518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487499#comment-16487499 ] ASF GitHub Bot commented on FLINK-8518: --- Github user snuyanzin commented on a diff i

[GitHub] flink pull request #6007: [FLINK-8518][Table API & SQL] Support DOW for EXTR...

Github user snuyanzin commented on a diff in the pull request: https://github.com/apache/flink/pull/6007#discussion_r190299515 --- Diff: flink-libraries/flink-table/src/test/scala/org/apache/flink/table/expressions/ScalarFunctionsTest.scala --- @@ -1473,6 +1473,14 @@ class ScalarF

[jira] [Created] (FLINK-9429) Quickstart E2E not working locally

Till Rohrmann created FLINK-9429: Summary: Quickstart E2E not working locally Key: FLINK-9429 URL: https://issues.apache.org/jira/browse/FLINK-9429 Project: Flink Issue Type: Bug Co

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487486#comment-16487486 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190296235 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * Li

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487481#comment-16487481 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190295347 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487473#comment-16487473 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190294307 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487470#comment-16487470 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190293752 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * Li

[jira] [Commented] (FLINK-9384) KafkaAvroTableSource failed to work due to type mismatch

[ https://issues.apache.org/jira/browse/FLINK-9384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487469#comment-16487469 ] ASF GitHub Bot commented on FLINK-9384: --- Github user tragicjun commented on the issu

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487468#comment-16487468 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190293256 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[GitHub] flink issue #6026: [FLINK-9384]KafkaAvroTableSource failed to work due to ty...

Github user tragicjun commented on the issue: https://github.com/apache/flink/pull/6026 @twalthr Thanks for the comment. I've commited a new version as per your suggestion. Particularly, I agree that TypeInfomation should always be derived from the 'avroRecrodClass', but the construct

[jira] [Updated] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown.

[ https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann updated FLINK-9427: - Affects Version/s: 1.6.0 > Cannot download from BlobServer, because the server address is unknown.

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487461#comment-16487461 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190290965 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[jira] [Assigned] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown.

[ https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-9427: Assignee: Till Rohrmann > Cannot download from BlobServer, because the server address is un

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487458#comment-16487458 ] ASF GitHub Bot commented on FLINK-9423: --- Github user StefanRRichter commented on a d

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190289953 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * Li

[jira] [Created] (FLINK-9428) Allow operators to flush data on checkpoint pre-barrier

Stephan Ewen created FLINK-9428: --- Summary: Allow operators to flush data on checkpoint pre-barrier Key: FLINK-9428 URL: https://issues.apache.org/jira/browse/FLINK-9428 Project: Flink Issue Typ

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487451#comment-16487451 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190288320 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[jira] [Commented] (FLINK-9386) Remove netty-router dependency

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

[GitHub] flink issue #6031: [FLINK-9386] Embed netty router

Github user uce commented on the issue: https://github.com/apache/flink/pull/6031 > I planned to upgrade netty and drop netty-router in one step of upgrading flink-shaded-netty. Do you think it should be split somehow? No, if the ticket for upgrading covers that, we are all good.

[jira] [Updated] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown.

[ https://issues.apache.org/jira/browse/FLINK-9427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-9427: -- Attachment: failure > Cannot download from BlobServer, because the server address is unknown. >

[jira] [Created] (FLINK-9427) Cannot download from BlobServer, because the server address is unknown.

Piotr Nowojski created FLINK-9427: - Summary: Cannot download from BlobServer, because the server address is unknown. Key: FLINK-9427 URL: https://issues.apache.org/jira/browse/FLINK-9427 Project: Flin

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487438#comment-16487438 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[jira] [Commented] (FLINK-9423) Implement efficient deletes for heap based timer service

[ https://issues.apache.org/jira/browse/FLINK-9423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487439#comment-16487439 ] ASF GitHub Bot commented on FLINK-9423: --- Github user sihuazhou commented on a diff i

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190285625 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/TimerHeapInternalTimer.java --- @@ -0,0 +1,235 @@ +/* + * Li

[GitHub] flink pull request #6062: [FLINK-9423][state] Implement efficient deletes fo...

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/6062#discussion_r190279440 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/InternalTimerHeap.java --- @@ -0,0 +1,504 @@ +/* + * License

[jira] [Commented] (FLINK-9411) Support parquet rolling sink writer

[ https://issues.apache.org/jira/browse/FLINK-9411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487436#comment-16487436 ] mingleizhang commented on FLINK-9411: - Thanks for your feedback, [~StephanEwen]. What

[jira] [Updated] (FLINK-9424) BlobClientSslTest does not work in all environments

[ https://issues.apache.org/jira/browse/FLINK-9424?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9424: Description: It seems that the {{BlobClientSslTest}} assumes SSL algorithms that are not present in

[GitHub] flink issue #5798: [FLINK-7917] The return of taskInformationOrBlobKey shoul...

Github user yanghua commented on the issue: https://github.com/apache/flink/pull/5798 cc @StefanRRichter ---

[jira] [Commented] (FLINK-7917) The return of taskInformationOrBlobKey should be placed inside synchronized in ExecutionJobVertex

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

[jira] [Commented] (FLINK-9386) Remove netty-router dependency

[ https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487419#comment-16487419 ] ASF GitHub Bot commented on FLINK-9386: --- Github user pnowojski commented on the issu

[GitHub] flink issue #6031: [FLINK-9386] Embed netty router

Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/6031 Thanks for the review and manual checks! I either addressed your comments in fixup commit and left comment responses otherwise. > Do we file a follow up ticket to remove netty-router from o

[jira] [Updated] (FLINK-9409) Remove flink-avro and flink-json from /opt

[ https://issues.apache.org/jira/browse/FLINK-9409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther updated FLINK-9409: Summary: Remove flink-avro and flink-json from /opt (was: Missing assembly-dependencies in flink-di

[jira] [Commented] (FLINK-9340) ScheduleOrUpdateConsumersTest may fail with Address already in use

[ https://issues.apache.org/jira/browse/FLINK-9340?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487397#comment-16487397 ] Ted Yu commented on FLINK-9340: --- Here is my env: Java HotSpot(TM) 64-Bit Server VM warning:

[jira] [Commented] (FLINK-9386) Remove netty-router dependency

[ https://issues.apache.org/jira/browse/FLINK-9386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16487382#comment-16487382 ] ASF GitHub Bot commented on FLINK-9386: --- Github user uce commented on a diff in the

  1   2   3   4   >