[GitHub] [flink] flinkbot edited a comment on issue #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#issuecomment-543851152 ## CI report: * 8c26cb49219cd022f5c7187b3b4c9b012295d798 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r337641855 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r337641104 ## File path: flink-dist/src/main/flink-bin/mesos-bin/mesos-appmaster-job.sh

[GitHub] [flink] tillrohrmann commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#discussion_r337642329 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970#issuecomment-544980056 ## CI report: * a2b9906d887c4feba3f1777957af4d3027116cb0 : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology URL: https://github.com/apache/flink/pull/9948#discussion_r337634821 ## File path:

[GitHub] [flink] flinkbot commented on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

2019-10-22 Thread GitBox
flinkbot commented on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#issuecomment-545056164 ## CI report: * 754bf46eea690059abc1919dd43d6e38f0d94c15 : UNKNOWN Bot commands The

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337636460 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#issuecomment-543851152 ## CI report: * 8c26cb49219cd022f5c7187b3b4c9b012295d798 : SUCCESS

[jira] [Resolved] (FLINK-13985) Use unsafe memory for managed memory.

2019-10-22 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin resolved FLINK-13985. - Resolution: Done Merged into master by afe216121e93b902a07e4e104ac94a73cf6a2877 > Use

[jira] [Updated] (FLINK-13985) Use unsafe memory for managed memory.

2019-10-22 Thread Andrey Zagrebin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Zagrebin updated FLINK-13985: Fix Version/s: 1.10.0 > Use unsafe memory for managed memory. >

[GitHub] [flink] azagrebin commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

2019-10-22 Thread GitBox
azagrebin commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337433462 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

2019-10-22 Thread GitBox
azagrebin commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337523213 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors

2019-10-22 Thread GitBox
azagrebin commented on a change in pull request #9928: [FLINK-12122] Add support for spreading slots out across all TaskExecutors URL: https://github.com/apache/flink/pull/9928#discussion_r337528633 ## File path:

[GitHub] [flink] azagrebin merged pull request #9747: [FLINK-13985] Use unsafe memory for managed memory

2019-10-22 Thread GitBox
azagrebin merged pull request #9747: [FLINK-13985] Use unsafe memory for managed memory URL: https://github.com/apache/flink/pull/9747 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb …

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9542: [FLINK-13873][metrics] Change the column family as tags for influxdb … URL: https://github.com/apache/flink/pull/9542#issuecomment-525276537 ## CI report: * e8636926351f3d406962dcadba275e20e49aff39 : SUCCESS

[GitHub] [flink] bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-22 Thread GitBox
bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#discussion_r337627904 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-22 Thread GitBox
bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#discussion_r337626193 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-22 Thread GitBox
bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#discussion_r337626193 ## File path:

[GitHub] [flink] bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-22 Thread GitBox
bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#discussion_r337619462 ## File path:

[GitHub] [flink] bowenli86 commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-22 Thread GitBox
bowenli86 commented on issue #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#issuecomment-545044122 the build has failed. can you fix it? This is an

[GitHub] [flink] flinkbot commented on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects

2019-10-22 Thread GitBox
flinkbot commented on issue #9971: [FLINK-14490][table] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971#issuecomment-545043476 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments

2019-10-22 Thread GitBox
bowenli86 commented on a change in pull request #9927: [FLINK-14397][hive] Failed to run Hive UDTF with array arguments URL: https://github.com/apache/flink/pull/9927#discussion_r337619462 ## File path:

[jira] [Updated] (FLINK-14490) Add methods for interacting with temporary objects

2019-10-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14490: --- Labels: pull-request-available (was: ) > Add methods for interacting with temporary

[GitHub] [flink] dawidwys opened a new pull request #9971: [FLINK-14490] Add methods for interacting with temporary objects

2019-10-22 Thread GitBox
dawidwys opened a new pull request #9971: [FLINK-14490] Add methods for interacting with temporary objects URL: https://github.com/apache/flink/pull/9971 ## What is the purpose of the change This PR adds methods for interacting with temporary objects as described in FLIP-64:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology URL: https://github.com/apache/flink/pull/9948#discussion_r337617564 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-537049332 ## CI report: * abaae048fef753455970fac9d6ab421b660b0536 : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337613201 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337613294 ## File path:

[jira] [Commented] (FLINK-14380) Type Extractor POJO setter check does not allow for Immutable Case Class

2019-10-22 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-14380?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957200#comment-16957200 ] Marco Zühlke commented on FLINK-14380: -- I bumped into the same case. Using a pure scala streaming

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337613034 ## File path: flink-core/src/test/java/org/apache/flink/util/IterableUtilsTest.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337612464 ## File path: flink-core/src/main/java/org/apache/flink/util/IterableUtils.java

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337612316 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337612595 ## File path: flink-core/src/main/java/org/apache/flink/util/IterableUtils.java

[jira] [Commented] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

2019-10-22 Thread Thomas Weise (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957197#comment-16957197 ] Thomas Weise commented on FLINK-14175: -- Given the nature of the issue I think it would be

[GitHub] [flink] zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
zhuzhurk commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337606076 ## File path:

[GitHub] [flink] tillrohrmann commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-22 Thread GitBox
tillrohrmann commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-545032285 I've force pushed a rebased version with a cleaned up commit history @TisonKun and @GJL.

[GitHub] [flink] flinkbot edited a comment on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970#issuecomment-544980056 ## CI report: * a2b9906d887c4feba3f1777957af4d3027116cb0 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#issuecomment-534982677 ## CI report: * d5e85b7a984024ea1aee2ce8bdf527d89c21e88e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS

[GitHub] [flink] tillrohrmann commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology URL: https://github.com/apache/flink/pull/9948#discussion_r337593317 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9948: [FLINK-14451][runtime] Refactor FailoverTopology to extend base topology URL: https://github.com/apache/flink/pull/9948#discussion_r337592103 ## File path:

[jira] [Commented] (FLINK-14175) Upgrade KPL version in flink-connector-kinesis to fix application OOM

2019-10-22 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957159#comment-16957159 ] Robert Metzger commented on FLINK-14175: [~thw]: Afaik you're using the Kinesis connector.

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337573087 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337565462 ## File path: flink-core/src/main/java/org/apache/flink/util/IterableUtils.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337567099 ## File path: flink-core/src/main/java/org/apache/flink/util/IterableUtils.java

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337570170 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337575410 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337572973 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9936: [FLINK-14450][runtime] Change SchedulingTopology to extend base topology URL: https://github.com/apache/flink/pull/9936#discussion_r337571137 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9881: [FLINK-14377] Parse Executor-relevant ProgramOptions to ConfigOptions

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9881: [FLINK-14377] Parse Executor-relevant ProgramOptions to ConfigOptions URL: https://github.com/apache/flink/pull/9881#issuecomment-541072480 ## CI report: * 03fb6e64db35f290c9a1d5552aa34dfe5ccf9cd8 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#issuecomment-534982677 ## CI report: * d5e85b7a984024ea1aee2ce8bdf527d89c21e88e : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9255: [FLINK-13034] Introduce isEmpty method for MapState URL: https://github.com/apache/flink/pull/9255#issuecomment-515870480 ## CI report: * de863750b7262d091d2e7dd82767b8f9b2e2c52a : SUCCESS

[jira] [Comment Edited] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

2019-10-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957142#comment-16957142 ] Piotr Nowojski edited comment on FLINK-14480 at 10/22/19 2:53 PM: -- > It

[jira] [Comment Edited] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

2019-10-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957142#comment-16957142 ] Piotr Nowojski edited comment on FLINK-14480 at 10/22/19 2:53 PM: -- > It

[jira] [Commented] (FLINK-14480) Sort out exception supression during snapshotting for non-running tasks.

2019-10-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957142#comment-16957142 ] Piotr Nowojski commented on FLINK-14480: > It looks that the expected behavior from connector is

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-22 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r337558729 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-22 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r337557586 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-22 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r337562191 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-22 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r337559908 ## File path:

[GitHub] [flink] AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence

2019-10-22 Thread GitBox
AHeise commented on a change in pull request #9735: [FLINK-14156][runtime] Submit timer trigger letters to task's mailbox with operator's precedence URL: https://github.com/apache/flink/pull/9735#discussion_r337560762 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9969: [FLINK-14022][table-planner][table-planner-blink] Add validation check for places where Python ScalarFunction cannot be used URL: https://github.com/apache/flink/pull/9969#issuecomment-54497 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9970: [FLINK-14395] Refactor ES 7 connectors to make them keep consistency with es 6 connectors URL: https://github.com/apache/flink/pull/9970#issuecomment-544980056 ## CI report: * a2b9906d887c4feba3f1777957af4d3027116cb0 : PENDING

[GitHub] [flink] GJL commented on a change in pull request #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling

2019-10-22 Thread GitBox
GJL commented on a change in pull request #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling URL: https://github.com/apache/flink/pull/9904#discussion_r337557327 ## File path:

[GitHub] [flink] GJL commented on issue #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling

2019-10-22 Thread GitBox
GJL commented on issue #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling URL: https://github.com/apache/flink/pull/9904#issuecomment-544996246 Generally speaking good. There are some minor comments.

[GitHub] [flink] GJL commented on a change in pull request #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling

2019-10-22 Thread GitBox
GJL commented on a change in pull request #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling URL: https://github.com/apache/flink/pull/9904#discussion_r337557327 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling

2019-10-22 Thread GitBox
GJL commented on a change in pull request #9904: [FLINK-14232][runtime] Support global failure handling in NG scheduling URL: https://github.com/apache/flink/pull/9904#discussion_r337558661 ## File path:

[jira] [Comment Edited] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

2019-10-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957127#comment-16957127 ] Piotr Nowojski edited comment on FLINK-14370 at 10/22/19 2:38 PM: -- My

[jira] [Commented] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

2019-10-22 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957127#comment-16957127 ] Piotr Nowojski commented on FLINK-14370: My work is done (flies away...) >

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337542866 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337547895 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337535771 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337550548 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337540039 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337541954 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337537252 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337536397 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337545560 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337543146 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337542388 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337547480 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337540714 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337540895 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337539829 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337538540 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337546469 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337534010 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337534745 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337550931 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337549036 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337539032 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337544085 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337536925 ## File path:

[GitHub] [flink] tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever

2019-10-22 Thread GitBox
tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r337538665 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters.

2019-10-22 Thread GitBox
flinkbot edited a comment on issue #9772: [FLINK-14199] Only use dedicated/named classes for mailbox letters. URL: https://github.com/apache/flink/pull/9772#issuecomment-534982677 ## CI report: * d5e85b7a984024ea1aee2ce8bdf527d89c21e88e : SUCCESS

[GitHub] [flink] TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session

2019-10-22 Thread GitBox
TisonKun commented on issue #9832: [FLINK-11843] Bind lifespan of Dispatcher to leader session URL: https://github.com/apache/flink/pull/9832#issuecomment-544990021 Thanks for your updates Till and thanks for answering my concerns on semantic level. Please ping me when you finish the

<    1   2   3   4   5   >