[jira] [Commented] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963983#comment-16963983 ] Till Rohrmann commented on FLINK-14164: --- The plan sounds good to me [~zhuzh]. I've assigned this

[jira] [Assigned] (FLINK-14164) Add a metric to show failover count regarding fine grained recovery

[ https://issues.apache.org/jira/browse/FLINK-14164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann reassigned FLINK-14164: - Assignee: Zhu Zhu > Add a metric to show failover count regarding fine grained

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341136224 ## File path:

[GitHub] [flink] wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341136224 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341174345 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341173178 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341179474 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341175289 ## File path:

[GitHub] [flink] zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

zentol commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341172664 ## File path:

[GitHub] [flink] GJL closed pull request #10043: [FLINK-14439][runtime] Enable RestartPipelinedRegionStrategy to leverage JM tracked partition availability in DefaultScheduler

GJL closed pull request #10043: [FLINK-14439][runtime] Enable RestartPipelinedRegionStrategy to leverage JM tracked partition availability in DefaultScheduler URL: https://github.com/apache/flink/pull/10043 This is an

[GitHub] [flink] GJL closed pull request #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it

GJL closed pull request #10044: [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase to enable scheduler NG testing for it URL: https://github.com/apache/flink/pull/10044 This is an automated message from the Apache

[GitHub] [flink] flinkbot edited a comment on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn.

flinkbot edited a comment on issue #10061: [FLINK-14581][python] Let python UDF execution no longer rely on the flink directory structure to support running python UDFs on yarn. URL: https://github.com/apache/flink/pull/10061#issuecomment-548335375 ## CI report: *

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341116077 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341157710 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

flinkbot edited a comment on issue #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#issuecomment-547440502 ## CI report: * 85d93043d366498b8bdaed5351b74ca47c77d575 : SUCCESS

[GitHub] [flink] pnowojski merged pull request #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

pnowojski merged pull request #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049 This is an automated message from the Apache Git Service. To

[jira] [Closed] (FLINK-14544) Resuming Externalized Checkpoint after terminal failure (file, async) end-to-end test fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-14544. -- Fix Version/s: 1.10.0 Resolution: Fixed merged to master as 8522f3b > Resuming

[GitHub] [flink] lirui-apache opened a new pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

lirui-apache opened a new pull request #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062 ## What is the purpose of the change To support Hive 1.0.0 and 1.0.1. ## Brief change log - Added

[GitHub] [flink] flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

flinkbot edited a comment on issue #10002: [FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10002#issuecomment-546597933 ## CI report: * 4c13fd02d0f6f98e18ddb04bd11581e0c378a7ca : UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor

flinkbot edited a comment on issue #10003: [BP-1.9][FLINK-14074][mesos] Forward configuration to Mesos TaskExecutor URL: https://github.com/apache/flink/pull/10003#issuecomment-546599805 ## CI report: * f51cd353402817c2a22946c857fe80cf6954fda3 : FAILURE

[jira] [Updated] (FLINK-14588) Support Hive version 1.0.0 and 1.0.1

[ https://issues.apache.org/jira/browse/FLINK-14588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-14588: --- Labels: pull-request-available (was: ) > Support Hive version 1.0.0 and 1.0.1 >

[GitHub] [flink] lirui-apache commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

lirui-apache commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548371621 cc @xuefuz @bowenli86 @zjuwangg This is an automated

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE

[GitHub] [flink] tillrohrmann commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

tillrohrmann commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341145835 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table

flinkbot edited a comment on issue #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 4937b8b139bab4957799947b841fb1ae3758ed48 : FAILURE

[GitHub] [flink] tillrohrmann commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

tillrohrmann commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341146660 ## File path:

[GitHub] [flink] flinkbot commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

flinkbot commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548389810 ## CI report: * 47e63a50352681e156100c5a35084ff927292910 : UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548389810 ## CI report: * 47e63a50352681e156100c5a35084ff927292910 : SUCCESS

[GitHub] [flink] wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

wsry commented on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-548386177 Many thanks to @pnowojski and @zhijiangW for the review. I adopted @pnowojski 's

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341181890 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341145634 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341114825 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341157710 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341119021 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341120305 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341116077 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341115208 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341192702 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341192586 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341192879 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341192663 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine

GJL commented on a change in pull request #9974: [FLINK-14501][FLINK-14502] Decouple ClusterDescriptor/ClusterSpecification from CommandLine URL: https://github.com/apache/flink/pull/9974#discussion_r341242448 ## File path:

[jira] [Commented] (FLINK-11127) Make metrics query service establish connection to JobManager

[ https://issues.apache.org/jira/browse/FLINK-11127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964210#comment-16964210 ] Hwanju Kim commented on FLINK-11127: [~tsubasa2oo2], in addition to what [~trohrmann] said (and it's

[GitHub] [flink] dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r341128392 ## File path:

[GitHub] [flink] dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table

dawidwys commented on a change in pull request #10059: [FLINK-14543][table] Support partition for temporary table URL: https://github.com/apache/flink/pull/10059#discussion_r341128392 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341145798 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341145693 ## File path:

[GitHub] [flink] azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341145951 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049#issuecomment-547930818 ## CI report: * 7e94dd883cdbfa5f32bdf727166366819f956a17 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource

flinkbot edited a comment on issue #10042: [FLINK-11466][e2e] Implement LocalStandaloneKafkaResource URL: https://github.com/apache/flink/pull/10042#issuecomment-547792578 ## CI report: * b523eace793d9168a2816e50891d6227183a7175 : FAILURE

[GitHub] [flink] kl0u commented on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

kl0u commented on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-548392411 I was thinking something like the `FileProcessingMode` in the `readFile` method.

[GitHub] [flink] flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049#issuecomment-547930818 ## CI report: * 7e94dd883cdbfa5f32bdf727166366819f956a17 : SUCCESS

[jira] [Assigned] (FLINK-14372) Enable KeyedStateCheckpointingITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao reassigned FLINK-14372: Assignee: Gary Yao > Enable KeyedStateCheckpointingITCase to pass with scheduler NG >

[jira] [Closed] (FLINK-14439) RestartPipelinedRegionStrategy leverage tracked partition availability for better failover experience in DefaultScheduler

[ https://issues.apache.org/jira/browse/FLINK-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14439. Resolution: Fixed 1.10: a966e44b525e694dd90be30206ed83ee341ed9a4 > RestartPipelinedRegionStrategy

[GitHub] [flink] azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

azagrebin commented on a change in pull request #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#discussion_r341146226 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch

flinkbot edited a comment on issue #9864: [FLINK-14254][table] Introduce FileSystemOutputFormat for batch URL: https://github.com/apache/flink/pull/9864#issuecomment-539910284 ## CI report: * e66114b1aa73a82b4c6bcf5c3a16baedb598f8c3 : FAILURE

[jira] [Commented] (FLINK-14558) Fix the ClassNotFoundException issue for run python job in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-14558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964057#comment-16964057 ] Hequn Cheng commented on FLINK-14558: - Fixed in 1.10.0 via 3a69d5b8af7fd131670fbf4479653b8700c8a3c4

[jira] [Closed] (FLINK-14558) Fix the ClassNotFoundException issue for run python job in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-14558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14558. --- Resolution: Fixed > Fix the ClassNotFoundException issue for run python job in standalone mode >

[GitHub] [flink] hequn8128 closed pull request #10045: [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator

hequn8128 closed pull request #10045: [FLINK-14558][python] Fix ClassNotFoundException of PythonScalarFunctionOperator URL: https://github.com/apache/flink/pull/10045 This is an automated message from the Apache Git

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r341162969 ## File path: flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java ## @@

[GitHub] [flink] kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

kl0u commented on a change in pull request #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#discussion_r341163172 ## File path: flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java ## @@

[GitHub] [flink] zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341170248 ## File path:

[GitHub] [flink] zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

zhuzhurk commented on a change in pull request #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#discussion_r341171431 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

flinkbot edited a comment on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548389810 ## CI report: * 47e63a50352681e156100c5a35084ff927292910 : PENDING

[GitHub] [flink] pnowojski commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

pnowojski commented on a change in pull request #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#discussion_r341203502 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : CANCELED

[jira] [Created] (FLINK-14588) Support Hive version 1.0.0 and 1.0.1

Rui Li created FLINK-14588: -- Summary: Support Hive version 1.0.0 and 1.0.1 Key: FLINK-14588 URL: https://issues.apache.org/jira/browse/FLINK-14588 Project: Flink Issue Type: Task

[GitHub] [flink] azagrebin commented on issue #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

azagrebin commented on issue #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#issuecomment-548388263 Thanks for the review @zentol, addressed comments The commit order looks correct now.

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

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

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341157747 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341157466 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341157954 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

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

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: *

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341164351 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341156074 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

[GitHub] [flink] flinkbot edited a comment on issue #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot

flinkbot edited a comment on issue #10034: [FLINK-14400] Shrink scope of MemoryManager from TaskExecutor to slot URL: https://github.com/apache/flink/pull/10034#issuecomment-547440502 ## CI report: * 85d93043d366498b8bdaed5351b74ca47c77d575 : SUCCESS

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

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

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341157610 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341156734 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341160757 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

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

tillrohrmann commented on a change in pull request #9950: [FLINK-14464][runtime] Introduce the AbstractUserClassPathJobGraphRetriever URL: https://github.com/apache/flink/pull/9950#discussion_r341156511 ## File path: flink-core/src/main/java/org/apache/flink/util/FileUtils.java

[GitHub] [flink] pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox

pnowojski commented on a change in pull request #10009: [FLINK-14304] Avoid task starvation with mailbox URL: https://github.com/apache/flink/pull/10009#discussion_r341114825 ## File path:

[jira] [Closed] (FLINK-14440) Enable BatchFineGrainedRecoveryITCase to pass with scheduler NG

[ https://issues.apache.org/jira/browse/FLINK-14440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao closed FLINK-14440. Resolution: Fixed 1.10: 6a25bc59503397b9c959d957624c654ba5b3d8e5 > Enable BatchFineGrainedRecoveryITCase

[jira] [Commented] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963982#comment-16963982 ] Dawid Wysakowicz commented on FLINK-13702: -- I don't know exactly how the {{JoinedRow}} is used

[GitHub] [flink] flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE

flinkbot edited a comment on issue #10035: [FLINK-14080][table-planner-blink] Introduce DateTime as internal representation of TIMESTAMP_WITHOUT_TIME_ZONE URL: https://github.com/apache/flink/pull/10035#issuecomment-547440593 ## CI report: *

[GitHub] [flink] flinkbot commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1

flinkbot commented on issue #10062: [FLINK-14588][hive] Support Hive version 1.0.0 and 1.0.1 URL: https://github.com/apache/flink/pull/10062#issuecomment-548373039 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your

[GitHub] [flink] flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation

flinkbot edited a comment on issue #10049: [FLINK-14544][runtime] Fixing race condition during task cancellation URL: https://github.com/apache/flink/pull/10049#issuecomment-547930818 ## CI report: * 7e94dd883cdbfa5f32bdf727166366819f956a17 : SUCCESS

[jira] [Comment Edited] (FLINK-13702) BaseMapSerializerTest.testDuplicate fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963982#comment-16963982 ] Dawid Wysakowicz edited comment on FLINK-13702 at 10/31/19 1:40 PM:

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[jira] [Commented] (FLINK-14569) use flink to deal with batch task,when parallelism granter than 1, always 1 or 2 records loss

[ https://issues.apache.org/jira/browse/FLINK-14569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964064#comment-16964064 ] kk commented on FLINK-14569: thank you  very much, use the api  

[GitHub] [flink] kl0u edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for …

kl0u edited a comment on issue #5521: [FLINK-8599] Improve the failure behavior of the FileInputFormat for … URL: https://github.com/apache/flink/pull/5521#issuecomment-548392411 I was thinking something like the `FileProcessingMode` in the `readFile` method. One `mode` being something

[GitHub] [flink] flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient

flinkbot edited a comment on issue #9972: [FLINK-14496][client] Exclude detach flag from ClusterClient URL: https://github.com/apache/flink/pull/9972#issuecomment-545092005 ## CI report: * 355939385e2951dd0da0e3fe1da8feb7dbc27f61 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor

flinkbot edited a comment on issue #9975: [FLINK-14477][coordination] Implement promotion logic on TaskExecutor URL: https://github.com/apache/flink/pull/9975#issuecomment-545348136 ## CI report: * 93c53cdbe080b7708e12f2f26dcd386684f8f125 : SUCCESS

[jira] [Commented] (FLINK-14565) Shutdown SystemResourcesCounter on (JM|TM)MetricGroup closed

[ https://issues.apache.org/jira/browse/FLINK-14565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16964115#comment-16964115 ] Chesnay Schepler commented on FLINK-14565: -- I would disagree that the

[GitHub] [flink] flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool.

flinkbot edited a comment on issue #9993: [FLINK-14498][runtime]Introduce NetworkBufferPool#isAvailable() for interacting with LocalBufferPool. URL: https://github.com/apache/flink/pull/9993#issuecomment-546219804 ## CI report: * f47a9f60dff6710ce5a7d5fe341a94d0fffb2d6d :

[GitHub] [flink] flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph

flinkbot edited a comment on issue #10006: [FLINK-14312][runtime] Support building logical pipelined regions from JobGraph URL: https://github.com/apache/flink/pull/10006#issuecomment-546671910 ## CI report: * 0697f19b0cce32ea7e70e0c13abe5a4a53d5 : CANCELED

[GitHub] [flink] flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

flinkbot edited a comment on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-532581942 ## CI report: * 1b930d19f27909ad5e2759eb6c5471c2ce07e8b4 : FAILURE

  1   2   3   4   5   >