[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343515164 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343513663 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343513353 ## File path:

[GitHub] [flink] flinkbot commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550964937 ## CI report: * 13118777453ff58976b17b9aa1b7a4590ce86d5c : UNKNOWN Bot

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 :

[GitHub] [flink] dawidwys merged pull request #10068: [FLINK-13702][FLINK-13740] Fixed issues with generic types and materialization of lazy binary formats in blink planner

dawidwys merged pull request #10068: [FLINK-13702][FLINK-13740] Fixed issues with generic types and materialization of lazy binary formats in blink planner URL: https://github.com/apache/flink/pull/10068 This is an

[GitHub] [flink] flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

flinkbot edited a comment on issue #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#issuecomment-549698167 ## CI report: * 9ad21545cdce68c8892941e8f33a89147bddb1f6 : SUCCESS

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343511776 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343511776 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

flinkbot edited a comment on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-547774074 ## CI report: * 5539c384788ae03243a246a891d1700e2f0be719 : FAILURE

[GitHub] [flink] xintongsong commented on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-550962331 Travis Passed: https://travis-ci.org/xintongsong/flink/builds/608570964

[GitHub] [flink] flinkbot commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

flinkbot commented on issue #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113#issuecomment-550962094 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[jira] [Updated] (FLINK-13749) Make Flink client respect classloading policy

[ https://issues.apache.org/jira/browse/FLINK-13749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13749: --- Labels: pull-request-available (was: ) > Make Flink client respect classloading policy >

[GitHub] [flink] link3280 opened a new pull request #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy

link3280 opened a new pull request #10113: [FLINK-13749][client] Make PackagedProgram respect classloading policy URL: https://github.com/apache/flink/pull/10113 ## What is the purpose of the change Currently, Flink client (PackagedProgram) does not respect the classloading policy and

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343508658 ## File path:

[GitHub] [flink] wuchong commented on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL

wuchong commented on issue #10039: [FLINK-14262][table] Support referencing function with fully/partially qualified names in SQL URL: https://github.com/apache/flink/pull/10039#issuecomment-550958252 Hi @bowenli86 , could you have another look at this commit

[GitHub] [flink] flinkbot commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

flinkbot commented on issue #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112#issuecomment-550958090 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[GitHub] [flink] flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-542644991 ## CI report: * 8d1696b97872fdd9fd3aca725c8b58ad8227f6f2 :

[jira] [Updated] (FLINK-14640) Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

[ https://issues.apache.org/jira/browse/FLINK-14640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14640: --- Labels: pull-request-available (was: ) > Change Type of Field currentExecutions from

[GitHub] [flink] yanghua opened a new pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap

yanghua opened a new pull request #10112: [FLINK-14640] Change Type of Field currentExecutions from ConcurrentHashMap to HashMap URL: https://github.com/apache/flink/pull/10112 ## What is the purpose of the change *This pull request changes Type of Field currentExecutions

[GitHub] [flink] flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

flinkbot edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550309075 ## CI report: * 9817ef9c8be75fd02ccef3825e706497f3e6c1b6 :

[GitHub] [flink] openinx commented on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

openinx commented on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550956528 Updated the pull request, FYI @zentol . Thanks.

[jira] [Created] (FLINK-14650) Thread safety issue in the piece of code example of dev/stream/testing document

Zhenghua Gao created FLINK-14650: Summary: Thread safety issue in the piece of code example of dev/stream/testing document Key: FLINK-14650 URL: https://issues.apache.org/jira/browse/FLINK-14650

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343503233 ## File path:

[jira] [Assigned] (FLINK-14644) Improve the usability of connector properties

[ https://issues.apache.org/jira/browse/FLINK-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-14644: --- Assignee: Jark Wu > Improve the usability of connector properties >

[jira] [Updated] (FLINK-14644) Improve the usability of connector properties

[ https://issues.apache.org/jira/browse/FLINK-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14644: Description: This is an umbrella issue to collect problems of current connector properties, especially

[jira] [Updated] (FLINK-14644) Improve the usability of connector properties

[ https://issues.apache.org/jira/browse/FLINK-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14644: Summary: Improve the usability of connector properties (was: Improve the userbility of connector

[jira] [Updated] (FLINK-14644) Improve the userbility of connector properties

[ https://issues.apache.org/jira/browse/FLINK-14644?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14644: Summary: Improve the userbility of connector properties (was: Improve CREATE TABLE DDL WITH properties)

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343500348 ## File path:

[jira] [Created] (FLINK-14649) Flatten all the connector properties keys to make it easy to configure in DDL

Jark Wu created FLINK-14649: --- Summary: Flatten all the connector properties keys to make it easy to configure in DDL Key: FLINK-14649 URL: https://issues.apache.org/jira/browse/FLINK-14649 Project: Flink

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343499645 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343499645 ## File path:

[GitHub] [flink] openinx edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it

openinx edited a comment on issue #10106: [FLINK-11463][e2e] Design the e2e java framework so that at least the Kafka streaming tests can run on it URL: https://github.com/apache/flink/pull/10106#issuecomment-550293379 The stale pull request are here:

[jira] [Created] (FLINK-14648) When using udaf, the startup task has a “Cannot determine simple type name 'com' ” exception

Ruiliang Li created FLINK-14648: --- Summary: When using udaf, the startup task has a “Cannot determine simple type name 'com' ” exception Key: FLINK-14648 URL: https://issues.apache.org/jira/browse/FLINK-14648

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE

[jira] [Created] (FLINK-14647) Improve the exception message when required property is not matched

Jark Wu created FLINK-14647: --- Summary: Improve the exception message when required property is not matched Key: FLINK-14647 URL: https://issues.apache.org/jira/browse/FLINK-14647 Project: Flink

[GitHub] [flink] flinkbot edited a comment on issue #10087: [flink-cep]Add wait state support for cep

flinkbot edited a comment on issue #10087: [flink-cep]Add wait state support for cep URL: https://github.com/apache/flink/pull/10087#issuecomment-549758621 ## CI report: * f78b7bfbde331e38dc74da29e0e36c83b7f1d49e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-542644991 ## CI report: * 8d1696b97872fdd9fd3aca725c8b58ad8227f6f2 :

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #10087: [flink-cep]Add wait state support for cep

flinkbot edited a comment on issue #10087: [flink-cep]Add wait state support for cep URL: https://github.com/apache/flink/pull/10087#issuecomment-549758621 ## CI report: * f78b7bfbde331e38dc74da29e0e36c83b7f1d49e : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-542644991 ## CI report: * 8d1696b97872fdd9fd3aca725c8b58ad8227f6f2 :

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-14646: --- Description: We should check non-null for {{key}} in {{selectChannel}} function in

[jira] [Updated] (FLINK-14646) Check non-null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao updated FLINK-14646: --- Summary: Check non-null for key in KeyGroupStreamPartitioner (was: Check null for key in

[GitHub] [flink] buptljy commented on issue #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema

buptljy commented on issue #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema URL: https://github.com/apache/flink/pull/10107#issuecomment-550819463 @KurtYoung Thanks for your review!

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE

[jira] [Closed] (FLINK-14608) avoid using Java Streams in JsonRowDeserializationSchema

[ https://issues.apache.org/jira/browse/FLINK-14608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Young closed FLINK-14608. -- Fix Version/s: 1.10.0 Resolution: Fixed merged in 1.10.0: 

[GitHub] [flink] KurtYoung merged pull request #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema

KurtYoung merged pull request #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema URL: https://github.com/apache/flink/pull/10107 This is an automated message from the Apache Git

[GitHub] [flink] KurtYoung commented on issue #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema

KurtYoung commented on issue #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema URL: https://github.com/apache/flink/pull/10107#issuecomment-550797799 LGTM, merging this... This is an

[GitHub] [flink] flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547346386 ## CI report: * a41da903ca8bcf9fc325107d2b11f19b76c5508e : FAILURE

[GitHub] [flink] danny0405 commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

danny0405 commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343481031 ## File path:

[GitHub] [flink] xintongsong commented on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-550795089 Thanks for the review, @azagrebin, @zhuzhurk, @KarmaGYZ. The comments are

[GitHub] [flink] xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r343478282 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-542644991 ## CI report: * 8d1696b97872fdd9fd3aca725c8b58ad8227f6f2 :

[jira] [Commented] (FLINK-14646) Check null for key in KeyGroupStreamPartitioner

[ https://issues.apache.org/jira/browse/FLINK-14646?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16968929#comment-16968929 ] Jiayi Liao commented on FLINK-14646: cc [~trohrmann] [~aljoscha] > Check null for key in

[GitHub] [flink] flinkbot edited a comment on issue #10111: [FLINK-1396] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

flinkbot edited a comment on issue #10111: [FLINK-1396] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis URL: https://github.com/apache/flink/pull/10111#issuecomment-550658607 ## CI report: *

[jira] [Created] (FLINK-14646) Check null for key in KeyGroupStreamPartitioner

Jiayi Liao created FLINK-14646: -- Summary: Check null for key in KeyGroupStreamPartitioner Key: FLINK-14646 URL: https://issues.apache.org/jira/browse/FLINK-14646 Project: Flink Issue Type:

[GitHub] [flink] buptljy commented on a change in pull request #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema

buptljy commented on a change in pull request #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema URL: https://github.com/apache/flink/pull/10107#discussion_r343476683 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-542644991 ## CI report: * 8d1696b97872fdd9fd3aca725c8b58ad8227f6f2 :

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE

[GitHub] [flink] danny0405 commented on a change in pull request #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

danny0405 commented on a change in pull request #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#discussion_r343473123 ## File path:

[GitHub] [flink] danny0405 commented on a change in pull request #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

danny0405 commented on a change in pull request #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#discussion_r343472986 ## File path:

[jira] [Created] (FLINK-14645) Data types defined in DDL will lose precision and nullability when converting to properties

Jark Wu created FLINK-14645: --- Summary: Data types defined in DDL will lose precision and nullability when converting to properties Key: FLINK-14645 URL: https://issues.apache.org/jira/browse/FLINK-14645

[GitHub] [flink] flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547346386 ## CI report: * a41da903ca8bcf9fc325107d2b11f19b76c5508e : FAILURE

[jira] [Created] (FLINK-14644) Improve CREATE TABLE DDL WITH properties

Jark Wu created FLINK-14644: --- Summary: Improve CREATE TABLE DDL WITH properties Key: FLINK-14644 URL: https://issues.apache.org/jira/browse/FLINK-14644 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

[ https://issues.apache.org/jira/browse/FLINK-14642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong updated FLINK-14642: Description: Currently, TupleSerializer and CaseCassSerializer do not support serialize NULL

[GitHub] [flink] zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts

zhuzhurk commented on a change in pull request #10082: [FLINK-14164][runtime] Add a counter ‘numberOfRestarts’ to show number of restarts URL: https://github.com/apache/flink/pull/10082#discussion_r343471170 ## File path: docs/monitoring/metrics.md ## @@ -1276,9 +1276,17

[jira] [Created] (FLINK-14643) Deprecate metric `fullRestarts`

Zhu Zhu created FLINK-14643: --- Summary: Deprecate metric `fullRestarts` Key: FLINK-14643 URL: https://issues.apache.org/jira/browse/FLINK-14643 Project: Flink Issue Type: Bug Components:

[jira] [Updated] (FLINK-14643) Deprecate metric `fullRestarts`

[ https://issues.apache.org/jira/browse/FLINK-14643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-14643: Issue Type: Improvement (was: Bug) > Deprecate metric `fullRestarts` > --- >

[jira] [Created] (FLINK-14642) Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values

Victor Wong created FLINK-14642: --- Summary: Flink TupleSerializer and CaseClassSerializer shoud support copy NULL values Key: FLINK-14642 URL: https://issues.apache.org/jira/browse/FLINK-14642 Project:

[jira] [Created] (FLINK-14641) Fix description of metric `fullRestarts`

Zhu Zhu created FLINK-14641: --- Summary: Fix description of metric `fullRestarts` Key: FLINK-14641 URL: https://issues.apache.org/jira/browse/FLINK-14641 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

flinkbot edited a comment on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-542644991 ## CI report: * 8d1696b97872fdd9fd3aca725c8b58ad8227f6f2 :

[GitHub] [flink] flinkbot edited a comment on issue #10111: [FLINK-1396] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

flinkbot edited a comment on issue #10111: [FLINK-1396] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis URL: https://github.com/apache/flink/pull/10111#issuecomment-550658607 ## CI report: *

[GitHub] [flink] zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r343469112 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

zhuzhurk commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r343469001 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343468822 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343468793 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

flinkbot edited a comment on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-547346386 ## CI report: * a41da903ca8bcf9fc325107d2b11f19b76c5508e : FAILURE

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343468425 ## File path:

[GitHub] [flink] wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

wuchong commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343468372 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r343466283 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r343465854 ## File path:

[GitHub] [flink] zhijiangW commented on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput

zhijiangW commented on issue #10029: [FLINK-14553][runtime] Respect non-blocking output in StreamTask#processInput URL: https://github.com/apache/flink/pull/10029#issuecomment-550660662 Thanks for the further review @AHeise ! I appended a fixup commit for addressing some comments.

[GitHub] [flink] xintongsong commented on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on issue #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#issuecomment-550659284 > It generally LGTM. > One comment, is the usage of `UNKNOWN` correct in

[GitHub] [flink] flinkbot commented on issue #10111: [FLINK-1396] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis

flinkbot commented on issue #10111: [FLINK-1396] Resuming Externalized Checkpoint (rocks, incremental, scale down) end-to-end test fails on Travis URL: https://github.com/apache/flink/pull/10111#issuecomment-550658607 ## CI report: * a0d4aa8de67de798d2d22546de60c9fb8c9cba2b :

[GitHub] [flink] flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc…

flinkbot edited a comment on issue #10096: [FLINK-14623][table-api] Add computed column information into TableSc… URL: https://github.com/apache/flink/pull/10096#issuecomment-550159742 ## CI report: * 3fd9876e046bb9a56f36995084b37675f3929e0d : FAILURE

[GitHub] [flink] KurtYoung commented on a change in pull request #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema

KurtYoung commented on a change in pull request #10107: [FLINK-14608] [flink-json] Avoid using Java Streams in JsonRowDeserializationSchema URL: https://github.com/apache/flink/pull/10107#discussion_r343464200 ## File path:

[jira] [Closed] (FLINK-12130) Apply command line options to configuration before installing security modules

[ https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-12130. --- Resolution: Won't Fix > Apply command line options to configuration before installing security

[GitHub] [flink] xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups.

xintongsong commented on a change in pull request #9910: [FLINK-14405][runtime] Align ResourceProfile/ResourceSpec fields with the new TaskExecutor memory setups. URL: https://github.com/apache/flink/pull/9910#discussion_r343464343 ## File path:

[jira] [Closed] (FLINK-12648) Load Hadoop file system via org.apache.hadoop.fs.FileSystem.get()

[ https://issues.apache.org/jira/browse/FLINK-12648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Victor Wong closed FLINK-12648. --- Resolution: Won't Fix > Load Hadoop file system via org.apache.hadoop.fs.FileSystem.get() >

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343460637 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343430509 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343461493 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343429427 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343455792 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343459880 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343461045 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343460478 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343463516 ## File path:

[GitHub] [flink] KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner

KurtYoung commented on a change in pull request #10098: [FLINK-14326][FLINK-14324][table] Support to apply watermark assigner in planner URL: https://github.com/apache/flink/pull/10098#discussion_r343458684 ## File path:

  1   2   3   4   5   6   7   >