[jira] [Commented] (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:comment-tabpanel=16606672#comment-16606672 ] ASF GitHub Bot commented on FLINK-9567: --- yanghua commented on issue #6669:

[GitHub] yanghua commented on issue #6669: [FLINK-9567][runtime][yarn] Fix the yarn container over allocation in…

yanghua commented on issue #6669: [FLINK-9567][runtime][yarn] Fix the yarn container over allocation in… URL: https://github.com/apache/flink/pull/6669#issuecomment-419313241 +1 This is an automated message from the Apache

[GitHub] tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs

tragicjun commented on issue #6508: [Flink-10079] [table] Automatically register sink table from external catalogs URL: https://github.com/apache/flink/pull/6508#issuecomment-419312921 @fhueske would you have a look at it?

[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=16606668#comment-16606668 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW commented on issue #6417: [FLINK-9913][runtime]

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

zhijiangW commented on issue #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#issuecomment-419312269 @pnowojski, I updated the codes for your comments and squashed it into the last commit. Wish your

[jira] [Updated] (FLINK-10240) Flexible scheduling strategy is needed for batch job

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10240: Description: Currently batch jobs are scheduled with LAZY_FROM_SOURCES strategy: source tasks are 

[jira] [Updated] (FLINK-10240) Flexible scheduling strategy is needed for batch job

[ https://issues.apache.org/jira/browse/FLINK-10240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-10240: Description: Currently batch jobs are scheduled with LAZY_FROM_SOURCES strategy: source tasks are 

[jira] [Commented] (FLINK-10243) Add option to reduce latency metrics granularity

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

[GitHub] Clarkkkkk commented on issue #6658: [FLINK-10243][metrics] Make latency metrics granularity configurable

Clark commented on issue #6658: [FLINK-10243][metrics] Make latency metrics granularity configurable URL: https://github.com/apache/flink/pull/6658#issuecomment-419305397 LGTM. Just one more proposal, could you add a global latency granularity to to the metrics, that could be a great

[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=16606651#comment-16606651 ] ASF GitHub Bot commented on FLINK-9913: --- zhijiangW commented on a change in pull request #6417:

[GitHub] zhijiangW commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter

zhijiangW commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r215832704 ## File path:

[jira] [Commented] (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:comment-tabpanel=16606634#comment-16606634 ] ASF GitHub Bot commented on FLINK-9567: --- Clark commented on issue #6669:

[GitHub] Clarkkkkk commented on issue #6669: [FLINK-9567][runtime][yarn] Fix the yarn container over allocation in…

Clark commented on issue #6669: [FLINK-9567][runtime][yarn] Fix the yarn container over allocation in… URL: https://github.com/apache/flink/pull/6669#issuecomment-419298559 cc @tillrohrmann Could you review this after travis gives green light?

[jira] [Commented] (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:comment-tabpanel=16606632#comment-16606632 ] ASF GitHub Bot commented on FLINK-9567: --- Clark opened a new pull request #6669:

[GitHub] Clarkkkkk opened a new pull request #6669: [FLINK-9567][runtime][yarn] Fix the yarn container over allocation in…

Clark opened a new pull request #6669: [FLINK-9567][runtime][yarn] Fix the yarn container over allocation in… URL: https://github.com/apache/flink/pull/6669 # Second commit for Flink-9567. The first commit ignore the region failover strategy could also cause the yarn container

[jira] [Reopened] (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 ] Shimin Yang reopened FLINK-9567: This issue also occurs while using region strategy. In that case the pending slot should also be

[GitHub] TisonKun opened a new pull request #6668: [hotfix] Clear YarnTestBase

TisonKun opened a new pull request #6668: [hotfix] Clear YarnTestBase URL: https://github.com/apache/flink/pull/6668 ## What is the purpose of the change Current YarnTestBase.java is very, very noisy. Each time one take a look at it would stuck because of out-of-order code layout.

[jira] [Assigned] (FLINK-10273) Access composite type fields after a function

[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rong Rong reassigned FLINK-10273: - Assignee: Rong Rong > Access composite type fields after a function >

[jira] [Commented] (FLINK-10273) Access composite type fields after a function

[ https://issues.apache.org/jira/browse/FLINK-10273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606511#comment-16606511 ] Rong Rong commented on FLINK-10273: --- Yup. I can take a deeper look at this problem actually. This has

[jira] [Created] (FLINK-10296) TypeExtractor only validates/matches exact POJO classes

James Morgan created FLINK-10296: Summary: TypeExtractor only validates/matches exact POJO classes Key: FLINK-10296 URL: https://issues.apache.org/jira/browse/FLINK-10296 Project: Flink

[jira] [Commented] (FLINK-10037) Document details event time behavior in a single location

[ https://issues.apache.org/jira/browse/FLINK-10037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606002#comment-16606002 ] ASF GitHub Bot commented on FLINK-10037: eliaslevy commented on issue #6481: [FLINK-10037]

[jira] [Commented] (FLINK-10193) Default RPC timeout is used when triggering savepoint via JobMasterGateway

[ https://issues.apache.org/jira/browse/FLINK-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16606004#comment-16606004 ] ASF GitHub Bot commented on FLINK-10193: tillrohrmann commented on issue #6601: [FLINK-10193]

[GitHub] tillrohrmann commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint

tillrohrmann commented on issue #6601: [FLINK-10193] Add @RpcTimeout to JobMasterGateway.triggerSavepoint URL: https://github.com/apache/flink/pull/6601#issuecomment-419152588 Thanks for the contribution @GJL. Merging this PR.

[GitHub] eliaslevy commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page

eliaslevy commented on issue #6481: [FLINK-10037] [Documentation] Add Event Time Details documentation page URL: https://github.com/apache/flink/pull/6481#issuecomment-419152527 @aljoscha @fhueske ping. Suggestions on how to move forward, or do we want to drop this?

[jira] [Commented] (FLINK-10222) Table scalar function expression parses error when function name equals the exists keyword suffix

[ https://issues.apache.org/jira/browse/FLINK-10222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605964#comment-16605964 ] ASF GitHub Bot commented on FLINK-10222: yanghua commented on issue #6622: [FLINK-10222] [table]

[GitHub] yanghua commented on issue #6622: [FLINK-10222] [table] Table scalar function expression parses error when function name equals the exists keyword suffix

yanghua commented on issue #6622: [FLINK-10222] [table] Table scalar function expression parses error when function name equals the exists keyword suffix URL: https://github.com/apache/flink/pull/6622#issuecomment-419146677 @twalthr If you have time, can you help me review this PR? It

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

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

[GitHub] yanghua commented on a change in pull request #6659: [FLINK-10281] [table] Table function parse regular expression contains backslash failed

yanghua commented on a change in pull request #6659: [FLINK-10281] [table] Table function parse regular expression contains backslash failed URL: https://github.com/apache/flink/pull/6659#discussion_r215679341 ## File path:

[GitHub] yanghua commented on a change in pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction

yanghua commented on a change in pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction URL: https://github.com/apache/flink/pull/6667#discussion_r215675005 ## File path:

[GitHub] yanghua commented on a change in pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction

yanghua commented on a change in pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction URL: https://github.com/apache/flink/pull/6667#discussion_r215675005 ## File path:

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

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

[GitHub] twalthr commented on a change in pull request #6659: [FLINK-10281] [table] Table function parse regular expression contains backslash failed

twalthr commented on a change in pull request #6659: [FLINK-10281] [table] Table function parse regular expression contains backslash failed URL: https://github.com/apache/flink/pull/6659#discussion_r215673314 ## File path:

[jira] [Commented] (FLINK-10229) Support listing of views

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

[GitHub] yanghua commented on issue #6631: [FLINK-10229] [sql-client] Support listing of views

yanghua commented on issue #6631: [FLINK-10229] [sql-client] Support listing of views URL: https://github.com/apache/flink/pull/6631#issuecomment-419138067 @twalthr Would you like to review this PR? thanks~ 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=16605923#comment-16605923 ] ASF GitHub Bot commented on FLINK-10074: yanghua commented on issue #6567: [FLINK-10074]

[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=16605920#comment-16605920 ] ASF GitHub Bot commented on FLINK-10074: yanghua commented on a change in pull request #6567:

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

yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-419137130 @azagrebin thanks for your suggestion, refactored this PR. This is

[GitHub] yanghua commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

yanghua commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#discussion_r215670211 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java

[jira] [Updated] (FLINK-7800) Enable window joins without equi-join predicates

[ https://issues.apache.org/jira/browse/FLINK-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-7800: -- Labels: pull-request-available (was: ) > Enable window joins without equi-join predicates >

[jira] [Commented] (FLINK-7800) Enable window joins without equi-join predicates

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

[GitHub] twalthr commented on issue #4934: [FLINK-7800] [table] Enable window joins without equi-join predicates

twalthr commented on issue #4934: [FLINK-7800] [table] Enable window joins without equi-join predicates URL: https://github.com/apache/flink/pull/4934#issuecomment-419133465 @xccui what is the status of this PR? You never received a review for it. Do you think the code is still valid and

[jira] [Assigned] (FLINK-5802) Flink SQL calling Hive User-Defined Functions

[ https://issues.apache.org/jira/browse/FLINK-5802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-5802: --- Assignee: (was: Zhuoluo Yang) > Flink SQL calling Hive User-Defined Functions >

[jira] [Assigned] (FLINK-5832) Support for simple hive UDF

[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther reassigned FLINK-5832: --- Assignee: (was: Zhuoluo Yang) > Support for simple hive UDF >

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

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

[jira] [Commented] (FLINK-5832) Support for simple hive UDF

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

[jira] [Updated] (FLINK-5832) Support for simple hive UDF

[ https://issues.apache.org/jira/browse/FLINK-5832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-5832: -- Labels: pull-request-available (was: ) > Support for simple hive UDF >

[GitHub] twalthr commented on issue #3456: [FLINK-5832] [table] Support for simple hive UDF

twalthr commented on issue #3456: [FLINK-5832] [table] Support for simple hive UDF URL: https://github.com/apache/flink/pull/3456#issuecomment-419125211 The PR has not been updated for a while and has a lot of merge conflicts. I will close it for now.

[GitHub] twalthr closed pull request #3456: [FLINK-5832] [table] Support for simple hive UDF

twalthr closed pull request #3456: [FLINK-5832] [table] Support for simple hive UDF URL: https://github.com/apache/flink/pull/3456 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

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605882#comment-16605882 ] Thomas Wozniakowski commented on FLINK-10184: - Hi [~till.rohrmann] Happy to help out with

[jira] [Commented] (FLINK-10184) HA Failover broken due to JobGraphs not being removed from Zookeeper on cancel

[ https://issues.apache.org/jira/browse/FLINK-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605866#comment-16605866 ] Till Rohrmann commented on FLINK-10184: --- I think this issue is the same as described in

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

[ https://issues.apache.org/jira/browse/FLINK-10255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-10255: - Assignee: Till Rohrmann > Standby Dispatcher locks submitted JobGraphs >

[jira] [Resolved] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

[ https://issues.apache.org/jira/browse/FLINK-10261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-10261. -- Resolution: Fixed Fix Version/s: 1.5.4 1.7.0

[jira] [Commented] (FLINK-9598) [Checkpoints] The config Minimum Pause Between Checkpoints doesn't work when there's a checkpoint failure

[ https://issues.apache.org/jira/browse/FLINK-9598?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605855#comment-16605855 ] ASF GitHub Bot commented on FLINK-9598: --- Myasuka commented on issue #6346: [FLINK-9598] Refine

[GitHub] Myasuka commented on issue #6346: [FLINK-9598] Refine java-doc about the min pause between checkpoints

Myasuka commented on issue #6346: [FLINK-9598] Refine java-doc about the min pause between checkpoints URL: https://github.com/apache/flink/pull/6346#issuecomment-419119077 @zentol I think the decision to change javadocs or fix checkpoint coordinator's behavior depends on whether we give

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

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

[GitHub] asfgit closed pull request #6648: [FLINK-10261][table] fix insert into with order by

asfgit closed pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648 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] dawidwys closed pull request #6644: [hotfix] check correct parameter

dawidwys closed pull request #6644: [hotfix] check correct parameter URL: https://github.com/apache/flink/pull/6644 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 foreign pull

[GitHub] TisonKun commented on issue #6644: [hotfix] check correct parameter

TisonKun commented on issue #6644: [hotfix] check correct parameter URL: https://github.com/apache/flink/pull/6644#issuecomment-419108664 cc @dawidwys This is an automated message from the Apache Git Service. To respond to

[jira] [Commented] (FLINK-10290) Conversion error in StreamScan and BatchScan

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

[GitHub] jrthe42 commented on issue #6666: [FLINK-10290] [table] Fix conversion error in StreamScan and BatchScan

jrthe42 commented on issue #: [FLINK-10290] [table] Fix conversion error in StreamScan and BatchScan URL: https://github.com/apache/flink/pull/#issuecomment-419107629 It would be nice if you could review this PR. @twalthr I checked the CI build failed error, and i thought

[jira] [Commented] (FLINK-10261) INSERT INTO does not work with ORDER BY clause

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

[GitHub] twalthr commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by

twalthr commented on a change in pull request #6648: [FLINK-10261][table] fix insert into with order by URL: https://github.com/apache/flink/pull/6648#discussion_r215628550 ## File path:

[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=16605753#comment-16605753 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on a change in pull request #6417:

[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=16605751#comment-16605751 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on a change in pull request #6417:

[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=16605750#comment-16605750 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on a change in pull request #6417:

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

pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r215613344 ## File path:

[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=16605754#comment-16605754 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on a change in pull request #6417:

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

pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r215611369 ## File path:

[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=16605752#comment-16605752 ] ASF GitHub Bot commented on FLINK-9913: --- pnowojski commented on a change in pull request #6417:

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

pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r215615035 ## File path:

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

pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r215611481 ## File path:

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

pnowojski commented on a change in pull request #6417: [FLINK-9913][runtime] Improve output serialization only once in RecordWriter URL: https://github.com/apache/flink/pull/6417#discussion_r215611435 ## File path:

[GitHub] dawidwys closed pull request #6649: [hotfix][flink-connector-filesystem] modify typo in BucketingSink

dawidwys closed pull request #6649: [hotfix][flink-connector-filesystem] modify typo in BucketingSink URL: https://github.com/apache/flink/pull/6649 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:

[GitHub] dawidwys commented on issue #6665: [FLINK-10293][streaming] Properly forward REST port for remote environments

dawidwys commented on issue #6665: [FLINK-10293][streaming] Properly forward REST port for remote environments URL: https://github.com/apache/flink/pull/6665#issuecomment-419082602 +1, LGTM This is an automated message from

[jira] [Commented] (FLINK-10293) RemoteStreamEnvironment does not forward port to RestClusterClient

[ https://issues.apache.org/jira/browse/FLINK-10293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605741#comment-16605741 ] ASF GitHub Bot commented on FLINK-10293: dawidwys commented on issue #6665:

[GitHub] dawidwys commented on a change in pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction

dawidwys commented on a change in pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction URL: https://github.com/apache/flink/pull/6667#discussion_r215613054 ## File path:

[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=16605727#comment-16605727 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on a change in pull request #6567:

[GitHub] azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#discussion_r215586087 ## File path:

[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=16605726#comment-16605726 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on a change in pull request #6567:

[GitHub] azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#discussion_r215586486 ## File path:

[GitHub] azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#discussion_r215588426 ## File path:

[GitHub] azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures

azagrebin commented on a change in pull request #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#discussion_r215586717 ## File path:

[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=16605725#comment-16605725 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on a change in pull request #6567:

[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=16605728#comment-16605728 ] ASF GitHub Bot commented on FLINK-10074: azagrebin commented on a change in pull request #6567:

[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=16605705#comment-16605705 ] ASF GitHub Bot commented on FLINK-10074: yanghua commented on issue #6567: [FLINK-10074]

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

yanghua commented on issue #6567: [FLINK-10074] Allowable number of checkpoint failures URL: https://github.com/apache/flink/pull/6567#issuecomment-419073463 @tillrohrmann and @zentol if you have time, can you have a look at this PR?

[jira] [Commented] (FLINK-10281) Table function parse regular expression contains backslash failed

[ https://issues.apache.org/jira/browse/FLINK-10281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605703#comment-16605703 ] ASF GitHub Bot commented on FLINK-10281: yanghua commented on issue #6659: [FLINK-10281] Table

[GitHub] yanghua commented on issue #6659: [FLINK-10281] Table function parse regular expression contains backslash failed

yanghua commented on issue #6659: [FLINK-10281] Table function parse regular expression contains backslash failed URL: https://github.com/apache/flink/pull/6659#issuecomment-419073183 @hequn8128 can you review this? This is

[GitHub] lamber-ken opened a new pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction

lamber-ken opened a new pull request #6667: [hotfix][docs] Fix error typo in CheckpointedFunction URL: https://github.com/apache/flink/pull/6667 ## What is the purpose of the change Fix error typo in CheckpointedFunction.java

[jira] [Commented] (FLINK-10208) Bump mockito to 2.0+

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

[GitHub] zentol commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5

zentol commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5 URL: https://github.com/apache/flink/pull/6634#discussion_r215578794 ## File path:

[jira] [Commented] (FLINK-10208) Bump mockito to 2.0+

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

[GitHub] zentol commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5

zentol commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5 URL: https://github.com/apache/flink/pull/6634#discussion_r215577408 ## File path:

[jira] [Assigned] (FLINK-9523) Add Kafka examples for Flink Table/SQL API

[ https://issues.apache.org/jira/browse/FLINK-9523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-9523: Assignee: Mikhail Sokolov > Add Kafka examples for Flink Table/SQL API >

[GitHub] NicoK commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5

NicoK commented on a change in pull request #6634: [FLINK-10208][build] Bump mockito to 2.21.0 / powermock to 2.0.0-beta.5 URL: https://github.com/apache/flink/pull/6634#discussion_r215573439 ## File path:

[jira] [Commented] (FLINK-10208) Bump mockito to 2.0+

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

[jira] [Commented] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605574#comment-16605574 ] Piotr Nowojski commented on FLINK-10257: This is another thing that complicates things even more

[jira] [Assigned] (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 ] vinoyang reassigned FLINK-10292: Assignee: vinoyang > Generate JobGraph in StandaloneJobClusterEntrypoint only once >

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605551#comment-16605551 ] Dominik Wosiński edited comment on FLINK-10052 at 9/6/18 9:48 AM: -- This

[jira] [Comment Edited] (FLINK-10052) Tolerate temporarily suspended ZooKeeper connections

[ https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16605551#comment-16605551 ] Chesnay Schepler edited comment on FLINK-10052 at 9/6/18 9:48 AM: --

  1   2   >