[jira] [Comment Edited] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment

[ https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16624449#comment-16624449 ] vinoyang edited comment on FLINK-10389 at 9/22/18 3:06 AM: --- Good catch, Does

[jira] [Commented] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment

[ https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16624449#comment-16624449 ] vinoyang commented on FLINK-10389: -- Good catach, Does it make sense to send a PR or "hotfix" to fix

[jira] [Assigned] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment

[ https://issues.apache.org/jira/browse/FLINK-10389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] vinoyang reassigned FLINK-10389: Assignee: vinoyang > TaskManagerServicesConfiguration ctor contains self assignment >

[jira] [Created] (FLINK-10391) MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils

Ted Yu created FLINK-10391: -- Summary: MillisOfDay is used in place of instant for LocalTime ctor in AvroKryoSerializerUtils Key: FLINK-10391 URL: https://issues.apache.org/jira/browse/FLINK-10391 Project:

[jira] [Created] (FLINK-10390) DataDog metric reporter leak warning

Elias Levy created FLINK-10390: -- Summary: DataDog metric reporter leak warning Key: FLINK-10390 URL: https://issues.apache.org/jira/browse/FLINK-10390 Project: Flink Issue Type: Improvement

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

[ https://issues.apache.org/jira/browse/FLINK-10298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16624217#comment-16624217 ] JIN SUN commented on FLINK-10298: - Hi Tison, Thanks for point this. Yes, i know there is a 

[jira] [Created] (FLINK-10389) TaskManagerServicesConfiguration ctor contains self assignment

Ted Yu created FLINK-10389: -- Summary: TaskManagerServicesConfiguration ctor contains self assignment Key: FLINK-10389 URL: https://issues.apache.org/jira/browse/FLINK-10389 Project: Flink Issue

[jira] [Comment Edited] (FLINK-10388) RestClientTest sometimes fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-10388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623945#comment-16623945 ] tison edited comment on FLINK-10388 at 9/21/18 5:49 PM: Maybe relevant to

[jira] [Commented] (FLINK-10388) RestClientTest sometimes fails with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-10388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623945#comment-16623945 ] tison commented on FLINK-10388: --- Maybe relevant to FLINK-4052 > RestClientTest sometimes fails with

[jira] [Created] (FLINK-10388) RestClientTest sometimes fails with AssertionError

Ted Yu created FLINK-10388: -- Summary: RestClientTest sometimes fails with AssertionError Key: FLINK-10388 URL: https://issues.apache.org/jira/browse/FLINK-10388 Project: Flink Issue Type: Test

[jira] [Commented] (FLINK-10378) Hide/Comment out contribute guide from PULL_REQUEST_TEMPLATE

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

[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=16623910#comment-16623910 ] ASF GitHub Bot commented on FLINK-10386: TisonKun commented on issue #6729: [FLINK-10386]

[GitHub] TisonKun commented on issue #6722: [FLINK-10378] [github] Comment out contribute guide from PULL_REQUEST_TEMPLATE

TisonKun commented on issue #6722: [FLINK-10378] [github] Comment out contribute guide from PULL_REQUEST_TEMPLATE URL: https://github.com/apache/flink/pull/6722#issuecomment-423611886 @StephanEwen travis-ci must fail on other issue.

[GitHub] TisonKun commented on issue #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener

TisonKun commented on issue #6729: [FLINK-10386] [taskmanager] Remove legacy class TaskExecutionStateListener URL: https://github.com/apache/flink/pull/6729#issuecomment-423611672 cc @StefanRRichter @zentol This is an

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

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

[GitHub] azagrebin edited a comment on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

azagrebin edited a comment on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-423573937 Thanks for the update, @yanghua. Looking at the checkpoint coordinator more deeply, I think we firstly have to work a bit

[jira] [Commented] (FLINK-10074) Allowable number of checkpoint failures

[ https://issues.apache.org/jira/browse/FLINK-10074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623775#comment-16623775 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on issue #6567: [FLINK-10074]

[GitHub] azagrebin commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures

azagrebin commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-423573937 Thanks for the update, @yanghua. Looking at the checkpoint coordinator more deeply, I think we firstly have to work a bit more on

[jira] [Commented] (FLINK-9999) Add ISNUMERIC supported in Table API/SQL

[ https://issues.apache.org/jira/browse/FLINK-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623770#comment-16623770 ] Dawid Wysakowicz commented on FLINK-: - I would be against adding this function. It is not

[jira] [Commented] (FLINK-10255) Standby Dispatcher locks submitted JobGraphs

[ https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623752#comment-16623752 ] ASF GitHub Bot commented on FLINK-10255: Clark commented on issue #6678: [FLINK-10255] Only

[GitHub] Clarkkkkk commented on issue #6678: [FLINK-10255] Only react to onAddedJobGraph signal when being leader

Clark commented on issue #6678: [FLINK-10255] Only react to onAddedJobGraph signal when being leader URL: https://github.com/apache/flink/pull/6678#issuecomment-423567013 Thanks for the reply, that'll make sense. This is

[jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI

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

[jira] [Commented] (FLINK-6847) Add TIMESTAMPDIFF supported in TableAPI

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

[GitHub] twalthr commented on a change in pull request #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support

twalthr commented on a change in pull request #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support URL: https://github.com/apache/flink/pull/6282#discussion_r219524046 ## File path:

[GitHub] twalthr commented on a change in pull request #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support

twalthr commented on a change in pull request #6282: [FLINK-6847][FLINK-6813] [table] TimestampDiff table api and sql support URL: https://github.com/apache/flink/pull/6282#discussion_r219524046 ## File path:

[jira] [Closed] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-8914. --- Resolution: Not A Problem Using proper AfterMatchSkip strategy you can achieve expected

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623721#comment-16623721 ] ASF GitHub Bot commented on FLINK-8914: --- Aitozi closed pull request #6124: [FLINK-8914][CEP]Fix

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623720#comment-16623720 ] ASF GitHub Bot commented on FLINK-8914: --- Aitozi commented on issue #6124: [FLINK-8914][CEP]Fix

[GitHub] Aitozi closed pull request #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern is the head of the pattern

Aitozi closed pull request #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern is the head of the pattern URL: https://github.com/apache/flink/pull/6124 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] Aitozi commented on issue #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern is the head of the pattern

Aitozi commented on issue #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern is the head of the pattern URL: https://github.com/apache/flink/pull/6124#issuecomment-423555799 Sure, closing. This is an automated

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219449333 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219486186 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219476983 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219485200 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219477941 ## File path:

[jira] [Commented] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623711#comment-16623711 ] ASF GitHub Bot commented on FLINK-8914: --- dawidwys commented on issue #6124: [FLINK-8914][CEP]Fix

[jira] [Updated] (FLINK-8914) CEP's greedy() modifier doesn't work

[ https://issues.apache.org/jira/browse/FLINK-8914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-8914: -- Labels: pull-request-available (was: ) > CEP's greedy() modifier doesn't work >

[GitHub] dawidwys commented on issue #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern is the head of the pattern

dawidwys commented on issue #6124: [FLINK-8914][CEP]Fix wrong semantic when greedy pattern is the head of the pattern URL: https://github.com/apache/flink/pull/6124#issuecomment-423553722 Hi @Aitozi. As I described previously, this case should be handled with greedy and proper

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

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

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219486325 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219517956 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219485512 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219485130 ## File path:

[GitHub] dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

dawidwys commented on a change in pull request #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#discussion_r219487366 ## File path:

[jira] [Commented] (FLINK-10379) Can not use Table Functions in Java Table API

[ https://issues.apache.org/jira/browse/FLINK-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623627#comment-16623627 ] Hequn Cheng commented on FLINK-10379: - Hi [~pnowojski] Thanks for sharing the information and

[jira] [Closed] (FLINK-10157) Allow `null` user values in map state with TTL

[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-10157. -- Resolution: Fixed Fix Version/s: 1.6.2 1.7.0 Merged in: master:

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

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

[GitHub] asfgit closed pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

asfgit closed pull request #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

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

[ https://issues.apache.org/jira/browse/FLINK-10384?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623521#comment-16623521 ] ASF GitHub Bot commented on FLINK-10384: yanghua commented on issue #6730: [FLINK-10384] Add

[GitHub] yanghua commented on issue #6730: [FLINK-10384] Add Sinh math function supported in Table API and SQL

yanghua commented on issue #6730: [FLINK-10384] Add Sinh math function supported in Table API and SQL URL: https://github.com/apache/flink/pull/6730#issuecomment-423516113 cc @xccui This is an automated message from the

[jira] [Commented] (FLINK-10320) Introduce JobMaster schedule micro-benchmark

[ https://issues.apache.org/jira/browse/FLINK-10320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623481#comment-16623481 ] Piotr Nowojski commented on FLINK-10320: [~till.rohrmann] might have a good point. [~Tison]

[jira] [Commented] (FLINK-10379) Can not use Table Functions in Java Table API

[ https://issues.apache.org/jira/browse/FLINK-10379?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623471#comment-16623471 ] Piotr Nowojski commented on FLINK-10379: Thanks [~hequn8128] :) Probably we should first also

[jira] [Commented] (FLINK-10157) Allow `null` user values in map state with TTL

[ https://issues.apache.org/jira/browse/FLINK-10157?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623467#comment-16623467 ] ASF GitHub Bot commented on FLINK-10157: StefanRRichter commented on issue #6707: [FLINK-10157]

[GitHub] StefanRRichter commented on issue #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL

StefanRRichter commented on issue #6707: [FLINK-10157] [State TTL] Allow `null` user values in map state with TTL URL: https://github.com/apache/flink/pull/6707#issuecomment-423507977 Thanks @azagrebin ! Changes look good to me, merging. 

[jira] [Closed] (FLINK-9983) Savepoints should count as checkpoints when recovering

[ https://issues.apache.org/jira/browse/FLINK-9983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-9983. --- Resolution: Duplicate Will be fixed in [FLINK-10354] > Savepoints should count as

[jira] [Commented] (FLINK-10354) Savepoints should be counted as retained checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623465#comment-16623465 ] Dawid Wysakowicz commented on FLINK-10354: -- You're right, haven't seen the other one. Will

[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=16623464#comment-16623464 ] Piotr Nowojski commented on FLINK-10339: I'm not aware about any concerns, but I'm also not very

[jira] [Commented] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

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

[GitHub] pnowojski commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif…

pnowojski commented on a change in pull request #6723: [FLINK-10377] Remove precondition in TwoPhaseCommitSinkFunction.notif… URL: https://github.com/apache/flink/pull/6723#discussion_r219471764 ## File path:

[jira] [Comment Edited] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623459#comment-16623459 ] tison edited comment on FLINK-8803 at 9/21/18 11:52 AM: is it "won't fix" since

[jira] [Commented] (FLINK-8803) Mini Cluster Shutdown with HA unstable, causing test failures

[ https://issues.apache.org/jira/browse/FLINK-8803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623459#comment-16623459 ] tison commented on FLINK-8803: -- is it "won't fix" since it's all about {{FlinkMiniCluster}} which based on

[jira] [Closed] (FLINK-9738) Provide a way to define Table Version Functions in Table API

[ https://issues.apache.org/jira/browse/FLINK-9738?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9738. - Resolution: Fixed Fix Version/s: 1.7.0 Merged as f2a67a1682249d83711030f4e55b824cb18336d7

[jira] [Assigned] (FLINK-9715) Support versioned joins with event time

[ https://issues.apache.org/jira/browse/FLINK-9715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-9715: - Assignee: Piotr Nowojski > Support versioned joins with event time >

[jira] [Closed] (FLINK-9714) Support versioned joins with processing time

[ https://issues.apache.org/jira/browse/FLINK-9714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9714. - Resolution: Fixed Fix Version/s: 1.7.0 Merged as 00add9cdc02ccfacb38a566099d877e4669c6f65

[jira] [Closed] (FLINK-9713) Support versioned joins in planning phase

[ https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9713. - Resolution: Fixed Fix Version/s: 1.7.0 Merged as 77c38346cb06b6e6c1bb672695c54f4ba253bd3f

[jira] [Closed] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-9913. - > Improve output serialization only once in RecordWriter >

[jira] [Resolved] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski resolved FLINK-9913. --- Resolution: Fixed merged commit 914dffb into apache:master > Improve output serialization

[jira] [Commented] (FLINK-9713) Support versioned joins in planning phase

[ https://issues.apache.org/jira/browse/FLINK-9713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623446#comment-16623446 ] ASF GitHub Bot commented on FLINK-9713: --- pnowojski commented on issue #6299:

[GitHub] pnowojski commented on issue #6299: [FLINK-9713][table][sql] Support processing time versioned joins

pnowojski commented on issue #6299: [FLINK-9713][table][sql] Support processing time versioned joins URL: https://github.com/apache/flink/pull/6299#issuecomment-423503610 Travis is green - merging This is an automated

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623432#comment-16623432 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski closed pull request #6417: [FLINK-9913][runtime]

[GitHub] pnowojski closed pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

pnowojski closed pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of

[jira] [Commented] (FLINK-9913) Improve output serialization only once in RecordWriter

[ https://issues.apache.org/jira/browse/FLINK-9913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623429#comment-16623429 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on issue #6417: [FLINK-9913][runtime]

[GitHub] pnowojski commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

pnowojski commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-423499421 @NicoK said to me his LGTM, so I'm merging this :) Thank you @zhijiangW for the contribution and the time

[jira] [Commented] (FLINK-10310) Cassandra Sink - Handling failing requests

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

[jira] [Updated] (FLINK-10310) Cassandra Sink - Handling failing requests

[ https://issues.apache.org/jira/browse/FLINK-10310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-10310: --- Labels: pull-request-available (was: ) > Cassandra Sink - Handling failing requests >

[GitHub] wittyameta opened a new pull request #6732: [FLINK-10310] Cassandra Sink - Handling failing requests.

wittyameta opened a new pull request #6732: [FLINK-10310] Cassandra Sink - Handling failing requests. URL: https://github.com/apache/flink/pull/6732 ## What is the purpose of the change This pull request provides support to optionally handle cassandra sink errors. A user may choose

[jira] [Commented] (FLINK-10354) Savepoints should be counted as retained checkpoints

[ https://issues.apache.org/jira/browse/FLINK-10354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623403#comment-16623403 ] Till Rohrmann commented on FLINK-10354: --- This looks like a duplicate of FLINK-9983? > Savepoints

[jira] [Commented] (FLINK-10263) User-defined function with LITERAL paramters yields CompileException

[ https://issues.apache.org/jira/browse/FLINK-10263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623381#comment-16623381 ] ASF GitHub Bot commented on FLINK-10263: twalthr commented on issue #6725: [FLINK-10263]

[GitHub] twalthr commented on issue #6725: [FLINK-10263] [sql-client] Fix classloader issues in SQL Client

twalthr commented on issue #6725: [FLINK-10263] [sql-client] Fix classloader issues in SQL Client URL: https://github.com/apache/flink/pull/6725#issuecomment-423486904 Thank you @dawidwys. I simplified the code there. This

[jira] [Created] (FLINK-10387) StateBackend create methods should return interface not abstract KeyedStateBackend classes

Gyula Fora created FLINK-10387: -- Summary: StateBackend create methods should return interface not abstract KeyedStateBackend classes Key: FLINK-10387 URL: https://issues.apache.org/jira/browse/FLINK-10387

[jira] [Commented] (FLINK-9682) Add setDescription to execution environment and provide description field for the rest api

[ https://issues.apache.org/jira/browse/FLINK-9682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623331#comment-16623331 ] ASF GitHub Bot commented on FLINK-9682: --- yanghua commented on issue #6266: [FLINK-9682] Add

[GitHub] yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api

yanghua commented on issue #6266: [FLINK-9682] Add setDescription to execution environment and provide description field for the rest api URL: https://github.com/apache/flink/pull/6266#issuecomment-423475109 @dawidwys any review suggestion?

[jira] [Commented] (FLINK-10363) S3 FileSystem factory prints secrets into logs

[ https://issues.apache.org/jira/browse/FLINK-10363?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623330#comment-16623330 ] Steve Loughran commented on FLINK-10363: see WHIRR-642 for this same issue; it's easy to do. For

[jira] [Resolved] (FLINK-10260) Confusing log during TaskManager registration

[ https://issues.apache.org/jira/browse/FLINK-10260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10260. --- Resolution: Fixed Fixed via 1.7.0: 542e8cc22290984b4b2e32577430ceb82dd82fde 1.6.2:

[jira] [Resolved] (FLINK-9567) Flink does not release resource in Yarn Cluster mode

[ https://issues.apache.org/jira/browse/FLINK-9567?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-9567. -- Resolution: Fixed Fix Version/s: (was: 1.5.1) (was: 1.6.0)

[jira] [Resolved] (FLINK-10375) ExceptionInChainedStubException hides wrapped exception in cause

[ https://issues.apache.org/jira/browse/FLINK-10375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-10375. --- Resolution: Fixed Fix Version/s: 1.5.5 1.6.2

[jira] [Commented] (FLINK-10282) Provide separate thread-pool for REST endpoint

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

[GitHub] TisonKun commented on issue #6661: FLINK-10282][runtime] Separate RPC and REST thread-pools

TisonKun commented on issue #6661: FLINK-10282][runtime] Separate RPC and REST thread-pools URL: https://github.com/apache/flink/pull/6661#issuecomment-423466269 Once introduce a new thread-pool to deal with REST tasks, we need to manage its lifecycle inside `WebMonitorEndpoint` instead

[jira] [Comment Edited] (FLINK-10312) Wrong / missing exception when submitting job

[ https://issues.apache.org/jira/browse/FLINK-10312?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623266#comment-16623266 ] Andrey Zagrebin edited comment on FLINK-10312 at 9/21/18 8:42 AM: -- PR

[jira] [Commented] (FLINK-10344) Rethink SubmittedJobGraphListener

[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16623273#comment-16623273 ] Biao Liu commented on FLINK-10344: -- [~dangdangdang] Oh that's my fault. I was reading a paper. Dragged

[jira] [Updated] (FLINK-10344) Rethink SubmittedJobGraphListener

[ https://issues.apache.org/jira/browse/FLINK-10344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Biao Liu updated FLINK-10344: - Attachment: (was: Tornado.pdf) > Rethink SubmittedJobGraphListener >

  1   2   >