[jira] [Resolved] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui resolved FLINK-10145. - Resolution: Fixed Fix Version/s: 1.7.0 Implemented in 1.7.0: 

[GitHub] asfgit closed pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL

asfgit closed pull request #6576: [FLINK-10145][table] Add replace supported in TableAPI and SQL URL: https://github.com/apache/flink/pull/6576 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

[jira] [Commented] (FLINK-10145) Add replace supported in TableAPI and SQL

[ https://issues.apache.org/jira/browse/FLINK-10145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629792#comment-16629792 ] ASF GitHub Bot commented on FLINK-10145: asfgit closed pull request #6576: [FLINK-10145][table]

[jira] [Comment Edited] (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=16629769#comment-16629769 ] tison edited comment on FLINK-10429 at 9/27/18 5:18 AM: I like the proposal

[jira] [Comment Edited] (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=16629769#comment-16629769 ] tison edited comment on FLINK-10429 at 9/27/18 5:18 AM: I like the proposal

[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=16629769#comment-16629769 ] tison commented on FLINK-10429: --- I like the proposal treat schedule a separated component. It is helpful

[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=16629735#comment-16629735 ] shuai.xu commented on FLINK-10429: -- +1 This proposal goes in the same direction as our approach. We

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629718#comment-16629718 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan edited a comment on issue #6544: [FLINK-8532]

[jira] [Commented] (FLINK-8532) RebalancePartitioner should use Random value for its first partition

[ https://issues.apache.org/jira/browse/FLINK-8532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629716#comment-16629716 ] ASF GitHub Bot commented on FLINK-8532: --- Guibo-Pan commented on issue #6544: [FLINK-8532]

[GitHub] Guibo-Pan edited a comment on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

Guibo-Pan edited a comment on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#issuecomment-424951099 cc @tillrohrmann @StephanEwen could you help advance this PR? Thanks.

[GitHub] Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition

Guibo-Pan commented on issue #6544: [FLINK-8532] [Streaming] modify RebalancePartitioner to use a random partition as its first partition URL: https://github.com/apache/flink/pull/6544#issuecomment-424951099 cc @tillrohrmann @StephanEwen could you help advance this PR?

[jira] [Commented] (FLINK-10418) Add COTH math function supported in Table API and SQL

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

[GitHub] yanghua commented on a change in pull request #6764: [FLINK-10418] [Table API & SQL] Add COTH math function supported in Table API and SQL

yanghua commented on a change in pull request #6764: [FLINK-10418] [Table API & SQL] Add COTH math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6764#discussion_r220784635 ## File path: docs/dev/table/functions.md ## @@ -1230,6 +1230,17

[jira] [Commented] (FLINK-10386) Remove legacy class TaskExecutionStateListener

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

[GitHub] TisonKun commented on a change in pull request #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener

TisonKun commented on a change in pull request #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener URL: https://github.com/apache/flink/pull/6729#discussion_r220779905 ## File path:

[jira] [Commented] (FLINK-10386) Remove legacy class TaskExecutionStateListener

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

[GitHub] TisonKun commented on a change in pull request #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener

TisonKun commented on a change in pull request #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener URL: https://github.com/apache/flink/pull/6729#discussion_r220779551 ## File path:

[jira] [Commented] (FLINK-10339) SpillReadBufferPool cannot use off-heap memory

[ https://issues.apache.org/jira/browse/FLINK-10339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629674#comment-16629674 ] ASF GitHub Bot commented on FLINK-10339: zhijiangW commented on issue #6762:

[GitHub] zhijiangW commented on issue #6762: [FLINK-10339][network] Use off-heap memory for SpillReadBufferPool

zhijiangW commented on issue #6762: [FLINK-10339][network] Use off-heap memory for SpillReadBufferPool URL: https://github.com/apache/flink/pull/6762#issuecomment-424935982 Thanks for your reviews! @StephanEwen That is a good idea for adding `allocateUnpooledOffHeapMemory` in the

[jira] [Commented] (FLINK-8594) Make producesUpdates in DataStreamGroupAggregate return false if it is a distinct group by without state retention configuration

[ https://issues.apache.org/jira/browse/FLINK-8594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629671#comment-16629671 ] Hequn Cheng commented on FLINK-8594: Hi [~twalthr], you are right. {{SELECT DISTINCT}} should be an

[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=16629571#comment-16629571 ] JIN SUN commented on FLINK-10429: - +1  I like the proposal, have put some comments in the document.  

[jira] [Created] (FLINK-10446) Use the "guava beta checker" plugin to keep off of @Beta API

Ted Yu created FLINK-10446: -- Summary: Use the "guava beta checker" plugin to keep off of @Beta API Key: FLINK-10446 URL: https://issues.apache.org/jira/browse/FLINK-10446 Project: Flink Issue

[jira] [Updated] (FLINK-10288) Failover Strategy improvement

[ https://issues.apache.org/jira/browse/FLINK-10288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10288: Fix Version/s: 1.7.0 > Failover Strategy improvement > - > >

[jira] [Updated] (FLINK-10298) Batch Job Failover Strategy

[ https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10298: Fix Version/s: 1.7.0 > Batch Job Failover Strategy > --- > > Key:

[jira] [Updated] (FLINK-10289) Classify Exceptions to different category for apply different failover strategy

[ https://issues.apache.org/jira/browse/FLINK-10289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10289: Fix Version/s: 1.7.0 > Classify Exceptions to different category for apply different failover > strategy

[jira] [Updated] (FLINK-10205) Batch Job: InputSplit Fault tolerant for DataSourceTask

[ https://issues.apache.org/jira/browse/FLINK-10205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JIN SUN updated FLINK-10205: Affects Version/s: 1.6.2 1.6.1 > Batch Job: InputSplit Fault tolerant for

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[jira] [Commented] (FLINK-9377) Remove writing serializers as part of the checkpoint meta information

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

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220738283 ## File path:

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220735704 ## File path:

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220734142 ## File path:

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220727617 ## File path:

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220738712 ## File path:

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220726336 ## File path:

[GitHub] StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints

StephanEwen commented on a change in pull request #6711: [FLINK-9377] [core, state backends] Remove serializers from checkpoints URL: https://github.com/apache/flink/pull/6711#discussion_r220739021 ## File path:

[jira] [Updated] (FLINK-10228) Add metrics for netty direct memory consumption

[ https://issues.apache.org/jira/browse/FLINK-10228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated FLINK-10228: --- Description: netty direct memory usage can be exposed via metrics so that operator can keep track of memory

[jira] [Closed] (FLINK-10444) Make S3 entropy injection work with FileSystem safety net

[ https://issues.apache.org/jira/browse/FLINK-10444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen closed FLINK-10444. > Make S3 entropy injection work with FileSystem safety net >

[jira] [Resolved] (FLINK-10444) Make S3 entropy injection work with FileSystem safety net

[ https://issues.apache.org/jira/browse/FLINK-10444?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stephan Ewen resolved FLINK-10444. -- Resolution: Fixed Fixed in - 1.6.2 via ec73c60aba5d564d8d946d82a4d7d0911e70dc9f - 1.7.0

[jira] [Commented] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

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

[GitHub] GJL commented on a change in pull request #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

GJL commented on a change in pull request #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#discussion_r220674263 ## File path:

[jira] [Commented] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

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

[jira] [Commented] (FLINK-9455) Make SlotManager aware of multi slot TaskManagers

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

[GitHub] GJL commented on a change in pull request #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

GJL commented on a change in pull request #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#discussion_r220674263 ## File path:

[GitHub] GJL commented on a change in pull request #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors

GJL commented on a change in pull request #6734: [FLINK-9455][RM] Add support for multi task slot TaskExecutors URL: https://github.com/apache/flink/pull/6734#discussion_r220674263 ## File path:

[jira] [Commented] (FLINK-10426) Port TaskTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629199#comment-16629199 ] tison commented on FLINK-10426: --- This sub tasks should consider to test {{Task}} fails if blobs missing.

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

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

[jira] [Updated] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10427: --- Labels: pull-request-available (was: ) > Port JobSubmitTest to new code base >

[GitHub] TisonKun opened a new pull request #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base

TisonKun opened a new pull request #6768: [FLINK-10427] [tests] Port JobSubmitTest to new code base URL: https://github.com/apache/flink/pull/6768 ## What is the purpose of the change Port `JobSubmitTest` to new code base ## Brief change log `JobSubmitTest` has three

[jira] [Comment Edited] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629002#comment-16629002 ] tison edited comment on FLINK-10427 at 9/26/18 5:47 PM:

[jira] [Updated] (FLINK-10406) Port JobManagerTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10406: --- Labels: pull-request-available (was: ) > Port JobManagerTest to new code base >

[jira] [Commented] (FLINK-10406) Port JobManagerTest to new code base

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

[GitHub] TisonKun commented on issue #6765: [FLINK-10406] [tests] Port JobManagerTest to new code base

TisonKun commented on issue #6765: [FLINK-10406] [tests] Port JobManagerTest to new code base URL: https://github.com/apache/flink/pull/6765#issuecomment-424804290 FYI, travis fails on `org.apache.flink.queryablestate.network.ClientTest#testSimpleRequests`, which I cannot reproduce

[jira] [Commented] (FLINK-10423) Forward RocksDB memory metrics to Flink metrics reporter

[ https://issues.apache.org/jira/browse/FLINK-10423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629155#comment-16629155 ] Seth Wiesman commented on FLINK-10423: -- [~srichter] I have a question about the best way to handle

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629130#comment-16629130 ] tison commented on FLINK-10427: --- {{testAnswerFailureWhenSavepointReadFails}} is covered by

[jira] [Commented] (FLINK-10415) RestClient does not react to lost connection

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

[GitHub] zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient

zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient URL: https://github.com/apache/flink/pull/6763#discussion_r220642450 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java

[GitHub] zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient

zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient URL: https://github.com/apache/flink/pull/6763#discussion_r220642544 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java

[jira] [Commented] (FLINK-10415) RestClient does not react to lost connection

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

[jira] [Commented] (FLINK-10415) RestClient does not react to lost connection

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

[GitHub] zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient

zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient URL: https://github.com/apache/flink/pull/6763#discussion_r220642737 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestClient.java

[jira] [Commented] (FLINK-10427) Port JobSubmitTest to new code base

[ https://issues.apache.org/jira/browse/FLINK-10427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629111#comment-16629111 ] tison commented on FLINK-10427: --- {{testFailureWhenInitializeOnMasterFails}} is covered by

[jira] [Commented] (FLINK-10380) Check if key is not nul before assign to group in KeyedStream

[ https://issues.apache.org/jira/browse/FLINK-10380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16629105#comment-16629105 ] ASF GitHub Bot commented on FLINK-10380: StephanEwen commented on issue #6724: [FLINK-10380] Add

[GitHub] StephanEwen commented on issue #6724: [FLINK-10380] Add precondition for assignToKeyGroup method

StephanEwen commented on issue #6724: [FLINK-10380] Add precondition for assignToKeyGroup method URL: https://github.com/apache/flink/pull/6724#issuecomment-424788457 Concerning the other method you mentioned: That one is never used on the critical path, so things may be different there.

[jira] [Commented] (FLINK-10415) RestClient does not react to lost connection

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

[GitHub] zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient

zentol commented on a change in pull request #6763: [FLINK-10415] Fail response future if connection closes in RestClient URL: https://github.com/apache/flink/pull/6763#discussion_r220638812 ## File path:

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

[jira] [Commented] (FLINK-9712) Support enrichment joins in Flink SQL/Table API

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

  1   2   3   4   >