[jira] [Commented] (FLINK-10429) Redesign Flink Scheduling, introducing dedicated Scheduler component

[ https://issues.apache.org/jira/browse/FLINK-10429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723766#comment-16723766 ] Alexander Lehmann commented on FLINK-10429: --- Like [~zhuzh] mentioned, a plugga

[GitHub] KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r242114883 ## File path: docs/dev/stream/state/state.md ## @@ -394,6 +396,47 @@ val ttlCo

[GitHub] KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend

KarmaGYZ commented on a change in pull request #7188: [FLINK-10473][State TTL] TTL state incremental cleanup for heap backend URL: https://github.com/apache/flink/pull/7188#discussion_r242114799 ## File path: docs/dev/stream/state/state.md ## @@ -394,6 +396,47 @@ val ttlCo

[jira] [Comment Edited] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-11180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723762#comment-16723762 ] sunjincheng edited comment on FLINK-11180 at 12/18/18 7:02 AM: ---

[jira] [Commented] (FLINK-11180) ProcessFailureCancelingITCase#testCancelingOnProcessFailure

[ https://issues.apache.org/jira/browse/FLINK-11180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723762#comment-16723762 ] sunjincheng commented on FLINK-11180: - Hi [~hequn8128] Thanks for take this JIRA. I

[GitHub] QiLuo-BD commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions

QiLuo-BD commented on issue #7186: [FLINK-10941] Keep slots which contain unconsumed result partitions URL: https://github.com/apache/flink/pull/7186#issuecomment-448115581 Hi Zhijiang/Till, Could you kindly share any further review on this? If no more comments, can this be merged?

[GitHub] xueyumusic commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes

xueyumusic commented on issue #7318: [FLINK-11099][Table API&SQL] Migrate flink-table runtime CRow Types classes URL: https://github.com/apache/flink/pull/7318#issuecomment-448114794 Hi, @XuQianJin-Stars , according to FLIP-28 it looks CRows may need to migrate into flink-table-runtime m

[jira] [Commented] (FLINK-11181) SimpleRecoveryITCaseBase test error

[ https://issues.apache.org/jira/browse/FLINK-11181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723753#comment-16723753 ] Hequn Cheng commented on FLINK-11181: - This is not a release blocker as it is a bug

[jira] [Commented] (FLINK-11181) SimpleRecoveryITCaseBase test error

[ https://issues.apache.org/jira/browse/FLINK-11181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723758#comment-16723758 ] sunjincheng commented on FLINK-11181: - Thanks for help me check this issue [~hequn81

[GitHub] sunjincheng121 commented on issue #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor…

sunjincheng121 commented on issue #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… URL: https://github.com/apache/flink/pull/7315#issuecomment-448112450 Hi @hequn8128 I had update the PR. appreciate if you can look at it again! Thanks, Jincheng --

[jira] [Assigned] (FLINK-11102) Enable check for previous data in SpanningRecordSerializer

[ https://issues.apache.org/jira/browse/FLINK-11102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] boshu Zheng reassigned FLINK-11102: --- Assignee: boshu Zheng (was: vinoyang) > Enable check for previous data in SpanningRecordSe

[jira] [Comment Edited] (FLINK-11182) JobManagerHACheckpointRecoveryITCase need be improved

[ https://issues.apache.org/jira/browse/FLINK-11182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723748#comment-16723748 ] sunjincheng edited comment on FLINK-11182 at 12/18/18 6:28 AM: ---

[jira] [Commented] (FLINK-11182) JobManagerHACheckpointRecoveryITCase need be improved

[ https://issues.apache.org/jira/browse/FLINK-11182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723748#comment-16723748 ] sunjincheng commented on FLINK-11182: - Yes, that's grate that FLINK-10392 will sol

[GitHub] leesf removed a comment on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

leesf removed a comment on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262#issuecomment-447745066 @tillrohrmann hi till, could you please merge this pr when you are free. Thanks -

[GitHub] leesf commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID

leesf commented on issue #7262: [FLINK-10478] Kafka Producer wrongly formats % for transaction ID URL: https://github.com/apache/flink/pull/7262#issuecomment-448110778 @tzulitai hi tzu, could you please merge this pr when you are free. Thanks ---

[jira] [Commented] (FLINK-11179) JoinCancelingITCase#testCancelSortMatchWhileDoingHeavySorting test error

[ https://issues.apache.org/jira/browse/FLINK-11179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723742#comment-16723742 ] sunjincheng commented on FLINK-11179: - The issue is not the blocker for release-1.7.

[GitHub] kisimple opened a new pull request #7321: [hotfix] Fix typo in AbstractStreamOperator

kisimple opened a new pull request #7321: [hotfix] Fix typo in AbstractStreamOperator URL: https://github.com/apache/flink/pull/7321 retrieven -> retrieved This is an automated message from the Apache Git Service. To respond

[GitHub] kisimple commented on issue #7192: [hotfix][test][streaming] Fix a test failure in Windows 7 environment.

kisimple commented on issue #7192: [hotfix][test][streaming] Fix a test failure in Windows 7 environment. URL: https://github.com/apache/flink/pull/7192#issuecomment-448099846 This would be an annoying problem when working on Windows. cc @kl0u -

[jira] [Commented] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723649#comment-16723649 ] Tzu-Li (Gordon) Tai commented on FLINK-11083: - Merged. master (1.8.0) - 45f

[jira] [Resolved] (FLINK-11083) CRowSerializerConfigSnapshot is not instantiable

[ https://issues.apache.org/jira/browse/FLINK-11083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai resolved FLINK-11083. - Resolution: Fixed > CRowSerializerConfigSnapshot is not instantiable > -

[GitHub] asfgit closed pull request #7267: [FLINK-11083][Table&SQL] CRowSerializerConfigSnapshot is not instantiable

asfgit closed pull request #7267: [FLINK-11083][Table&SQL] CRowSerializerConfigSnapshot is not instantiable URL: https://github.com/apache/flink/pull/7267 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 proven

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723617#comment-16723617 ] lining edited comment on FLINK-11162 at 12/18/18 3:28 AM: -- [~ya

[GitHub] Clarkkkkk commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation

Clark commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation URL: https://github.com/apache/flink/pull/7258#issuecomment-448084237 @walterddr Good point, I will tag it. ---

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723629#comment-16723629 ] lining commented on FLINK-11162: [~till.rohrmann] [~Zentol], what is your point? > Prov

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723629#comment-16723629 ] lining edited comment on FLINK-11162 at 12/18/18 3:29 AM: -- [~ti

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723617#comment-16723617 ] lining edited comment on FLINK-11162 at 12/18/18 3:25 AM: -- [~ya

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723617#comment-16723617 ] lining edited comment on FLINK-11162 at 12/18/18 3:24 AM: -- [~ya

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723623#comment-16723623 ] vinoyang commented on FLINK-11162: -- My initial thought was to add to jobs:/jobid/plan,

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723617#comment-16723617 ] lining edited comment on FLINK-11162 at 12/18/18 3:19 AM: -- [~ya

[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r242392587 ## File path: flink-libraries/flink-table/src/main/scala/or

[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r242392503 ## File path: flink-libraries/flink-table/src/main/scala/or

[GitHub] walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction

walterddr commented on a change in pull request #7237: [FLINK-7209] [table] Support DataView in Tuple and Case Class as the ACC type of AggregateFunction URL: https://github.com/apache/flink/pull/7237#discussion_r242393559 ## File path: flink-libraries/flink-table/src/main/scala/or

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723617#comment-16723617 ] lining commented on FLINK-11162: [~yanghua] we need add this information in which api, c

[jira] [Commented] (FLINK-11184) Rework TableSource and TableSink interfaces

[ https://issues.apache.org/jira/browse/FLINK-11184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723603#comment-16723603 ] Wenlong Lyu commented on FLINK-11184: - Hi, Timo, I think there is one more issue may

[GitHub] XiaoZYang closed pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

XiaoZYang closed pull request #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector URL: https://github.com/apache/flink/pull/5845 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 provenance: As this is a

[GitHub] XiaoZYang commented on issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector

XiaoZYang commented on issue #5845: [FLINK-9168][flink-connectors]Pulsar Sink connector URL: https://github.com/apache/flink/pull/5845#issuecomment-448070113 @sijie @tzulitai Thank you for your works and suggestions, I'm going to close this PR, any other advice? --

[jira] [Commented] (FLINK-11172) Remove the max retention time in StreamQueryConfig

[ https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723586#comment-16723586 ] Hequn Cheng commented on FLINK-11172: - Hi all, thanks for your discussion and sugges

[jira] [Created] (FLINK-11188) Bounded over should not enable state retention time

Hequn Cheng created FLINK-11188: --- Summary: Bounded over should not enable state retention time Key: FLINK-11188 URL: https://issues.apache.org/jira/browse/FLINK-11188 Project: Flink Issue Type

[jira] [Assigned] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-11162: Assignee: lining (was: vinoyang) > Provide a rest API to list all logical operators > --

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723560#comment-16723560 ] vinoyang commented on FLINK-11162: -- [~lining] Done. > Provide a rest API to list all l

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723559#comment-16723559 ] lining edited comment on FLINK-11162 at 12/18/18 1:30 AM: -- [~ya

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723559#comment-16723559 ] lining edited comment on FLINK-11162 at 12/18/18 1:29 AM: -- [~ya

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723559#comment-16723559 ] lining commented on FLINK-11162: [~yanghua] ok > Provide a rest API to list all logical

[jira] [Commented] (FLINK-11129) dashbord for job which contain important information

[ https://issues.apache.org/jira/browse/FLINK-11129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723557#comment-16723557 ] lining commented on FLINK-11129: [~till.rohrmann] [~Zentol]. Now, user need click many p

[jira] [Assigned] (FLINK-11129) dashbord for job which contain important information

[ https://issues.apache.org/jira/browse/FLINK-11129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining reassigned FLINK-11129: -- Assignee: lining > dashbord for job which contain important information > ---

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723553#comment-16723553 ] vinoyang commented on FLINK-11162: -- [~lining] Sounds good. I hope to see this PR as soo

[jira] [Comment Edited] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723551#comment-16723551 ] lining edited comment on FLINK-11162 at 12/18/18 1:20 AM: -- [~ya

[jira] [Commented] (FLINK-11162) Provide a rest API to list all logical operators

[ https://issues.apache.org/jira/browse/FLINK-11162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723551#comment-16723551 ] lining commented on FLINK-11162: [~yanghua] we have done this. After the web refactor, w

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723547#comment-16723547 ] vinoyang commented on FLINK-11103: -- Oh, I see you mentioned FLINK-5232, and it mainly a

[jira] [Commented] (FLINK-11146) Get rid of legacy codes from ClusterClient

[ https://issues.apache.org/jira/browse/FLINK-11146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723520#comment-16723520 ] TisonKun commented on FLINK-11146: -- Thanks for your explanation [~mxm]. Given JobClient

[GitHub] TisonKun commented on issue #7302: [FLINK-11156] [tests] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9

TisonKun commented on issue #7302: [FLINK-11156] [tests] Reconcile ZooKeeperCompletedCheckpointStoreMockitoTest with JDK 9 URL: https://github.com/apache/flink/pull/7302#issuecomment-448048599 @GJL for "It is not obvious why Comparator.comparing does not work.", I did a survey and i

[GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor…

sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… URL: https://github.com/apache/flink/pull/7315#discussion_r242356994 ## File path: flink-tests/src/test/java/org/apache/flink/test/cancelling/JoinCance

[GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor…

sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… URL: https://github.com/apache/flink/pull/7315#discussion_r242356994 ## File path: flink-tests/src/test/java/org/apache/flink/test/cancelling/JoinCance

[GitHub] sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor…

sunjincheng121 commented on a change in pull request #7315: [FLINK-11179][tests] add wait time for every record for testCancelSor… URL: https://github.com/apache/flink/pull/7315#discussion_r242356994 ## File path: flink-tests/src/test/java/org/apache/flink/test/cancelling/JoinCance

[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-448037747 @azagrebin ,I've just updated the code, please help to review it when you have time.

[jira] [Commented] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues

[ https://issues.apache.org/jira/browse/FLINK-11187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723402#comment-16723402 ] Addison Higham commented on FLINK-11187: See [https://lists.apache.org/thread.h

[jira] [Created] (FLINK-11187) StreamingFileSink with S3 backend transient socket timeout issues

Addison Higham created FLINK-11187: -- Summary: StreamingFileSink with S3 backend transient socket timeout issues Key: FLINK-11187 URL: https://issues.apache.org/jira/browse/FLINK-11187 Project: Flink

[GitHub] tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

tweise commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r242281357 ## File path: flink-streaming-java/src/main/java/org/apache/flink/str

[jira] [Comment Edited] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723279#comment-16723279 ] Sayat Satybaldiyev edited comment on FLINK-11171 at 12/17/18 7:11 PM:

[jira] [Commented] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723279#comment-16723279 ] Sayat Satybaldiyev commented on FLINK-11171: [~yunta] agrees, the exception

[GitHub] mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore

mxm commented on a change in pull request #7249: [FLINK-11048] Ability to programmatically execute streaming pipeline with savepoint restore URL: https://github.com/apache/flink/pull/7249#discussion_r242276315 ## File path: flink-streaming-java/src/main/java/org/apache/flink/stream

[GitHub] walterddr commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation

walterddr commented on issue #7258: [FLINK-11084]Throw a hard exception to remind developers while there's no stream node between two split transformation URL: https://github.com/apache/flink/pull/7258#issuecomment-447930223 Thanks for the PR @Clark . based on the JIRA discussion, shoul

[GitHub] walterddr commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible

walterddr commented on issue #7286: [FLINK-8739] [table] Optimize DISTINCT aggregates to use the same distinct accumulator if possible URL: https://github.com/apache/flink/pull/7286#issuecomment-447920610 @dianfu thanks for the explanation. I can see that #7253 has been merged. would you p

[jira] [Commented] (FLINK-11158) Do not show empty page for unknown jobs

[ https://issues.apache.org/jira/browse/FLINK-11158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723165#comment-16723165 ] Nico Kruber commented on FLINK-11158: - Thanks for the update. I guess, it would be n

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

klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241639512 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/ma

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

klion26 commented on a change in pull request #6777: [FLINK-10461] [State Backends, Checkpointing] Speed up download files when restore from DFS URL: https://github.com/apache/flink/pull/6777#discussion_r241949427 ## File path: flink-state-backends/flink-statebackend-rocksdb/src/ma

[jira] [Comment Edited] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723157#comment-16723157 ] Nico Kruber edited comment on FLINK-11103 at 12/17/18 4:54 PM: ---

[jira] [Commented] (FLINK-11103) Set a default uncaught exception handler

[ https://issues.apache.org/jira/browse/FLINK-11103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723157#comment-16723157 ] Nico Kruber commented on FLINK-11103: - Maybe I did not look into FLINK-5232 thorough

[jira] [Updated] (FLINK-9680) Reduce heartbeat timeout for E2E tests

[ https://issues.apache.org/jira/browse/FLINK-9680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9680: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Reduce heartbeat timeout f

[jira] [Assigned] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin reassigned FLINK-11171: --- Assignee: Andrey Zagrebin > Unexpected timestamp deserialization failure in RocksDB

[GitHub] azagrebin opened a new pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer

azagrebin opened a new pull request #7320: [FLINK-11171] Avoid concurrent usage of StateSnapshotTransformer URL: https://github.com/apache/flink/pull/7320 ## What is the purpose of the change StateSnapshotTransformer objects are now created when state is initialised. Afterwards, the

[jira] [Updated] (FLINK-11171) Unexpected timestamp deserialization failure in RocksDB state backend

[ https://issues.apache.org/jira/browse/FLINK-11171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-11171: --- Labels: pull-request-available (was: ) > Unexpected timestamp deserialization failure in Ro

[jira] [Updated] (FLINK-10292) Generate JobGraph in StandaloneJobClusterEntrypoint only once

[ https://issues.apache.org/jira/browse/FLINK-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10292: Fix Version/s: (was: 1.6.3) 1.6.4 > Generate JobGraph in St

[jira] [Updated] (FLINK-10251) Handle oversized response messages in AkkaRpcActor

[ https://issues.apache.org/jira/browse/FLINK-10251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10251: Fix Version/s: (was: 1.6.3) 1.6.4 > Handle oversized respon

[jira] [Updated] (FLINK-10721) kafkaFetcher runFetchLoop throw exception will cause follow-up code not execute in FlinkKafkaConsumerBase run method

[ https://issues.apache.org/jira/browse/FLINK-10721?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10721: Fix Version/s: (was: 1.6.3) 1.6.4 > kafkaFetcher runFetchLo

[jira] [Updated] (FLINK-9812) SpanningRecordSerializationTest fails on travis

[ https://issues.apache.org/jira/browse/FLINK-9812?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9812: --- Fix Version/s: (was: 1.6.3) 1.6.4 > SpanningRecordSerializatio

[jira] [Commented] (FLINK-11172) Remove the max retention time in StreamQueryConfig

[ https://issues.apache.org/jira/browse/FLINK-11172?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16723115#comment-16723115 ] Fabian Hueske commented on FLINK-11172: --- Hi, time-based operations (GROUP BY windo

[jira] [Updated] (FLINK-9485) Improving Flink’s timer management for large state

[ https://issues.apache.org/jira/browse/FLINK-9485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9485: --- Fix Version/s: (was: 1.6.4) > Improving Flink’s timer management for large state

[jira] [Updated] (FLINK-10079) Support external sink table in INSERT INTO statement

[ https://issues.apache.org/jira/browse/FLINK-10079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10079: Fix Version/s: (was: 1.6.3) 1.6.4 > Support external sink t

[jira] [Updated] (FLINK-9469) Add tests that cover PatternStream#flatSelect

[ https://issues.apache.org/jira/browse/FLINK-9469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9469: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Add tests that cover Patte

[jira] [Updated] (FLINK-7991) Cleanup kafka example jar filters

[ https://issues.apache.org/jira/browse/FLINK-7991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-7991: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Cleanup kafka example jar

[jira] [Updated] (FLINK-11151) FileUploadHandler stops working if the upload directory is removed

[ https://issues.apache.org/jira/browse/FLINK-11151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11151: Fix Version/s: (was: 1.6.3) 1.6.4 > FileUploadHandler stops

[jira] [Updated] (FLINK-11023) Update LICENSE and NOTICE files for flink-connectors

[ https://issues.apache.org/jira/browse/FLINK-11023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11023: Fix Version/s: (was: 1.6.3) 1.6.4 > Update LICENSE and NOTI

[jira] [Updated] (FLINK-9010) NoResourceAvailableException with FLIP-6

[ https://issues.apache.org/jira/browse/FLINK-9010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9010: --- Fix Version/s: (was: 1.6.3) 1.6.4 > NoResourceAvailableExcepti

[jira] [Updated] (FLINK-9253) Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

[ https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9253: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Make buffer count per Inpu

[jira] [Updated] (FLINK-9228) log details about task fail/task manager is shutting down

[ https://issues.apache.org/jira/browse/FLINK-9228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9228: --- Fix Version/s: (was: 1.6.3) 1.6.4 > log details about task fai

[jira] [Updated] (FLINK-11079) Update LICENSE and NOTICE files for flnk-storm-examples

[ https://issues.apache.org/jira/browse/FLINK-11079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11079: Fix Version/s: (was: 1.6.3) 1.6.4 > Update LICENSE and NOTI

[jira] [Updated] (FLINK-11107) [state] Avoid memory stateBackend to create arbitrary folders under HA path when no checkpoint path configured

[ https://issues.apache.org/jira/browse/FLINK-11107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-11107: Fix Version/s: (was: 1.6.3) 1.6.4 > [state] Avoid memory st

[jira] [Updated] (FLINK-10954) Hardlink from files of previous local stored state might cross devices

[ https://issues.apache.org/jira/browse/FLINK-10954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10954: Fix Version/s: (was: 1.6.3) 1.6.4 > Hardlink from files of

[jira] [Updated] (FLINK-11186) Support for event-time balancing for multiple Kafka partitions

[ https://issues.apache.org/jira/browse/FLINK-11186?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Schamberger updated FLINK-11186: Summary: Support for event-time balancing for multiple Kafka partitions (was: Support for

[jira] [Updated] (FLINK-10435) Client sporadically hangs after Ctrl + C

[ https://issues.apache.org/jira/browse/FLINK-10435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10435: Fix Version/s: (was: 1.6.3) 1.6.4 > Client sporadically han

[jira] [Updated] (FLINK-9879) Find sane defaults for (advanced) SSL session parameters

[ https://issues.apache.org/jira/browse/FLINK-9879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9879: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Find sane defaults for (ad

[jira] [Updated] (FLINK-9749) Rework Bucketing Sink

[ https://issues.apache.org/jira/browse/FLINK-9749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9749: --- Fix Version/s: (was: 1.6.3) > Rework Bucketing Sink > - > >

[jira] [Updated] (FLINK-10317) Configure Metaspace size by default

[ https://issues.apache.org/jira/browse/FLINK-10317?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10317: Fix Version/s: (was: 1.6.3) 1.6.4 > Configure Metaspace siz

[jira] [Updated] (FLINK-9776) Interrupt TaskThread only while in User/Operator code

[ https://issues.apache.org/jira/browse/FLINK-9776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9776: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Interrupt TaskThread only

[jira] [Updated] (FLINK-10241) Reduce performance/stability impact of latency metrics

[ https://issues.apache.org/jira/browse/FLINK-10241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-10241: Fix Version/s: (was: 1.6.3) > Reduce performance/stability impact of latency m

[jira] [Updated] (FLINK-9525) Missing META-INF/services/*FileSystemFactory in flink-hadoop-fs module

[ https://issues.apache.org/jira/browse/FLINK-9525?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9525: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Missing META-INF/services/

[jira] [Updated] (FLINK-9457) Cancel container requests when cancelling pending slot allocations

[ https://issues.apache.org/jira/browse/FLINK-9457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9457: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Cancel container requests

[jira] [Updated] (FLINK-8899) Submitting YARN job with FLIP-6 may lead to ApplicationAttemptNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-8899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-8899: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Submitting YARN job with F

[jira] [Updated] (FLINK-9142) Lower the minimum number of buffers for incoming channels to 1

[ https://issues.apache.org/jira/browse/FLINK-9142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tzu-Li (Gordon) Tai updated FLINK-9142: --- Fix Version/s: (was: 1.6.3) 1.6.4 > Lower the minimum number o

  1   2   3   >