[jira] [Updated] (FLINK-16962) Convert DatadogReporter to plugin

[ https://issues.apache.org/jira/browse/FLINK-16962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16962: - Parent Issue: FLINK-16963 (was: FLINK-16222) > Convert DatadogReporter to plugin >

[jira] [Created] (FLINK-16964) Convert Dropwizard reporter to plugin

Chesnay Schepler created FLINK-16964: Summary: Convert Dropwizard reporter to plugin Key: FLINK-16964 URL: https://issues.apache.org/jira/browse/FLINK-16964 Project: Flink Issue Type:

[jira] [Created] (FLINK-16962) Convert DatadogReporter to plugin

Chesnay Schepler created FLINK-16962: Summary: Convert DatadogReporter to plugin Key: FLINK-16962 URL: https://issues.apache.org/jira/browse/FLINK-16962 Project: Flink Issue Type:

[jira] [Commented] (FLINK-14763) flink sql cep parallelism error

[ https://issues.apache.org/jira/browse/FLINK-14763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074424#comment-17074424 ] baijingjing commented on FLINK-14763: - [~yantianyu] did you solve this problem? I encounter this

[GitHub] [flink] flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check

flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check URL: https://github.com/apache/flink/pull/11587#issuecomment-606986240 ## CI report: * 7a4c54e5ff25cf5d65766b0acff2f8d9ebf70cd1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator

flinkbot edited a comment on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator URL: https://github.com/apache/flink/pull/11625#issuecomment-608312573 ## CI report: * f63ceb4c101488d6df12f0314f30de2ef6aca411 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer

flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer URL: https://github.com/apache/flink/pull/11602#issuecomment-607241516 ## CI report: * 39d9b1a9c461fc940a660b95a4764f9982ba1599 Travis:

[GitHub] [flink] flinkbot commented on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44

flinkbot commented on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44 URL: https://github.com/apache/flink/pull/11626#issuecomment-608322234 ## CI report: * 10cea4c8ba6756ac31de11a5a6728a5dfc41d9c4 UNKNOWN Bot commands The @flinkbot bot supports the following

[GitHub] [flink] flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

flinkbot edited a comment on issue #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#issuecomment-593234780 ## CI report: * 1eee3c75e8c4619e988a2886c725c277b723e71c Travis:

[jira] [Updated] (FLINK-14713) Show Attempt History in Vertex SubTask In Rest Api

[ https://issues.apache.org/jira/browse/FLINK-14713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14713: --- Description: Flink jobs could recovery by failover, but the user couldn't see any information about the

[GitHub] [flink] zentol commented on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44

zentol commented on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44 URL: https://github.com/apache/flink/pull/11626#issuecomment-608319354 Any input on whether to backport this PR to 1.10/1.9 would be appreciated. This

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r402857921 ## File path:

[GitHub] [flink] flinkbot commented on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44

flinkbot commented on issue #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44 URL: https://github.com/apache/flink/pull/11626#issuecomment-608318425 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We will

[GitHub] [flink] zentol opened a new pull request #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44

zentol opened a new pull request #11626: [FLINK-16961] Bump Netty 4.X to 4.1.44 URL: https://github.com/apache/flink/pull/11626 To address multiple CVEs in netty. This is an automated message from the Apache Git Service. To

[jira] [Updated] (FLINK-16961) Bump Netty 4 to 4.1.44

[ https://issues.apache.org/jira/browse/FLINK-16961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16961: --- Labels: pull-request-available (was: ) > Bump Netty 4 to 4.1.44 > -- >

[GitHub] [flink] zhijiangW commented on issue #11088: [FLINK-16012][runtime] Reduce the default number of buffers per channel from 2 to 1

zhijiangW commented on issue #11088: [FLINK-16012][runtime] Reduce the default number of buffers per channel from 2 to 1 URL: https://github.com/apache/flink/pull/11088#issuecomment-608314828 > we might prefer in the end to just advertise two main different setups: full throughput with 2

[GitHub] [flink] rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints

rkhachatryan commented on a change in pull request #11515: [FLINK-16744][task] implement channel state persistence for unaligned checkpoints URL: https://github.com/apache/flink/pull/11515#discussion_r402845457 ## File path:

[GitHub] [flink] flinkbot commented on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator

flinkbot commented on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator URL: https://github.com/apache/flink/pull/11625#issuecomment-608312573 ## CI report: * f63ceb4c101488d6df12f0314f30de2ef6aca411 UNKNOWN Bot commands The @flinkbot bot

[GitHub] [flink] flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#issuecomment-607168470 ## CI report: * 6849f6c616060c7ecb85f65a9a915b6b3182710d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check

flinkbot edited a comment on issue #11587: [FLINK-14126][test] Ensure elasticsearch version check URL: https://github.com/apache/flink/pull/11587#issuecomment-606986240 ## CI report: * 7a4c54e5ff25cf5d65766b0acff2f8d9ebf70cd1 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on issue #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * bb66dde54a93c102fd23bdc75515f3d446006b7d Travis:

[jira] [Updated] (FLINK-16961) Bump Netty 4 to 4.1.44

[ https://issues.apache.org/jira/browse/FLINK-16961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16961: - Issue Type: Improvement (was: Bug) > Bump Netty 4 to 4.1.44 > -- >

[jira] [Created] (FLINK-16961) Bump Netty 4 to 4.1.44

Chesnay Schepler created FLINK-16961: Summary: Bump Netty 4 to 4.1.44 Key: FLINK-16961 URL: https://issues.apache.org/jira/browse/FLINK-16961 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-15305) MemoryMappedBoundedDataTest fails with IOException on ppc64le

[ https://issues.apache.org/jira/browse/FLINK-15305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-15305. -- Resolution: Fixed merged commit 13ef823 into apache:master Thanks for the fix [~kevin.cyj]

[GitHub] [flink] pnowojski merged pull request #11591: [FLINK-15305][tests] Make BoundedDataTestBase#testGetSizeMultipleRegions respect system page size to avoid potential failure

pnowojski merged pull request #11591: [FLINK-15305][tests] Make BoundedDataTestBase#testGetSizeMultipleRegions respect system page size to avoid potential failure URL: https://github.com/apache/flink/pull/11591 This is an

[jira] [Commented] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074408#comment-17074408 ] Robert Metzger commented on FLINK-16921: Thanks a lot for your contribution! > "kubernetes

[jira] [Updated] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16921: --- Fix Version/s: 1.11.0 > "kubernetes session test" is unstable >

[jira] [Resolved] (FLINK-16921) "kubernetes session test" is unstable

[ https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-16921. Assignee: Yang Wang Resolution: Fixed merged to master in

[GitHub] [flink] rmetzger merged pull request #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

rmetzger merged pull request #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] rmetzger commented on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

rmetzger commented on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619#issuecomment-608306281 I'm merging the PR now. This is an automated message from the

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402835387 ## File path:

[GitHub] [flink] pnowojski commented on issue #11088: [FLINK-16012][runtime] Reduce the default number of buffers per channel from 2 to 1

pnowojski commented on issue #11088: [FLINK-16012][runtime] Reduce the default number of buffers per channel from 2 to 1 URL: https://github.com/apache/flink/pull/11088#issuecomment-608306057 > try to gather the data for the 0 exclusive buffers first I meant 0 exclusive buffers for

[jira] [Closed] (FLINK-16772) Bump derby to 10.12.1.1+ or exclude it

[ https://issues.apache.org/jira/browse/FLINK-16772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-16772. Resolution: Fixed master: 0c94de1b968f4f9da8dd101d97292ccf8bd66d04 1.10:

[jira] [Comment Edited] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074397#comment-17074397 ] YufeiLiu edited comment on FLINK-16938 at 4/3/20, 8:33 AM: --- Hi [~jark], I

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402833540 ## File path:

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074402#comment-17074402 ] Kurt Young commented on FLINK-16636: Found 2 suspicious log from the output: The first one is:  

[GitHub] [flink] zentol merged pull request #11610: [FLINK-16772][hive] Move derby dependency to test scope

zentol merged pull request #11610: [FLINK-16772][hive] Move derby dependency to test scope URL: https://github.com/apache/flink/pull/11610 This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-607942457 ## CI report: *

[jira] [Comment Edited] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074397#comment-17074397 ] YufeiLiu edited comment on FLINK-16938 at 4/3/20, 8:26 AM: --- Hi [~jark], I

[jira] [Commented] (FLINK-16938) SqlTimestamp has lag when convert long to Timestamp

[ https://issues.apache.org/jira/browse/FLINK-16938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074397#comment-17074397 ] YufeiLiu commented on FLINK-16938: -- Hi [~jark], I think timestamp  doesn't have timezone, there are

[GitHub] [flink] rmetzger commented on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

rmetzger commented on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619#issuecomment-608301698 The e2e failure is known: https://issues.apache.org/jira/browse/FLINK-16423 Since the failing e2e test is running after the

[jira] [Updated] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-16423: --- Priority: Blocker (was: Critical) > test_ha_per_job_cluster_datastream.sh gets stuck >

[jira] [Commented] (FLINK-16423) test_ha_per_job_cluster_datastream.sh gets stuck

[ https://issues.apache.org/jira/browse/FLINK-16423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074396#comment-17074396 ] Robert Metzger commented on FLINK-16423:

[GitHub] [flink] flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

flinkbot edited a comment on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#issuecomment-607168470 ## CI report: * 6849f6c616060c7ecb85f65a9a915b6b3182710d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer

flinkbot edited a comment on issue #11602: [FLINK-16912][parquet] Introduce table row write support for parquet writer URL: https://github.com/apache/flink/pull/11602#issuecomment-607241516 ## CI report: * 39d9b1a9c461fc940a660b95a4764f9982ba1599 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on issue #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * bb66dde54a93c102fd23bdc75515f3d446006b7d Travis:

[GitHub] [flink] zentol commented on a change in pull request #11587: [FLINK-14126][test] Ensure elasticsearch version check

zentol commented on a change in pull request #11587: [FLINK-14126][test] Ensure elasticsearch version check URL: https://github.com/apache/flink/pull/11587#discussion_r402827772 ## File path: flink-end-to-end-tests/test-scripts/elasticsearch-common.sh ## @@ -26,7 +26,7 @@

[GitHub] [flink] flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

flinkbot edited a comment on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-604812212 ## CI report: * b5ef19285000d692d6b1b8b0aa7a37ce35c216f5 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on issue #11574: [FLINK-16859][table-runtime] Introduce file system table factory

flinkbot edited a comment on issue #11574: [FLINK-16859][table-runtime] Introduce file system table factory URL: https://github.com/apache/flink/pull/11574#issuecomment-606453374 ## CI report: * 415f37b7a4c03d5591c9352f593eaecb23bc1cf3 UNKNOWN *

[GitHub] [flink] flinkbot commented on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator

flinkbot commented on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator URL: https://github.com/apache/flink/pull/11625#issuecomment-608299559 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402824407 ## File path:

[GitHub] [flink] aljoscha commented on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator

aljoscha commented on issue #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator URL: https://github.com/apache/flink/pull/11625#issuecomment-608299030 I copied the code from the master branch, so there's also a small fix included for

[GitHub] [flink] aljoscha opened a new pull request #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator

aljoscha opened a new pull request #11625: [FLINK-16954] Don't use JDK11 APIs in ClassRelocator URL: https://github.com/apache/flink/pull/11625 We instead use asm-7, which is normally not available in the Flink 1.9.x line, as a test dependency. cc @zentol

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402823026 ## File path:

[jira] [Updated] (FLINK-16954) ClassRelocator uses JDK 11 APIs

[ https://issues.apache.org/jira/browse/FLINK-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16954: --- Labels: pull-request-available (was: ) > ClassRelocator uses JDK 11 APIs >

[GitHub] [flink] rkhachatryan commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata

rkhachatryan commented on issue #11491: [FLINK-16513][checkpointing] Unaligned checkpoints: checkpoint metadata URL: https://github.com/apache/flink/pull/11491#issuecomment-608296987 @carp84 can you please take a look at this PR?

[jira] [Assigned] (FLINK-16954) ClassRelocator uses JDK 11 APIs

[ https://issues.apache.org/jira/browse/FLINK-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek reassigned FLINK-16954: Assignee: Aljoscha Krettek > ClassRelocator uses JDK 11 APIs >

[GitHub] [flink] HuangZhenQiu commented on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on issue #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#issuecomment-608296022 Thanks for the suggestions. I updated the PR accordingly. My major concern is to add a TestingNettyClient. It

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402818491 ## File path:

[GitHub] [flink] dianfu commented on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF

dianfu commented on issue #11598: [FLINK-16914][python] Support ArrayType in vectorized Python UDF URL: https://github.com/apache/flink/pull/11598#issuecomment-608295450 @JingsongLi Thanks for the review. Most points make sense to me and have updated the PR.

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402815971 ## File path:

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

Jiayi-Liao commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402815632 ## File path:

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#discussion_r402815267 ## File path:

[GitHub] [flink] dawidwys edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

dawidwys edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-608293818 Hi @carp84, 1. The affected ctors of

[jira] [Updated] (FLINK-16955) Bump Zookeeper 3.4.X to 3.4.14

[ https://issues.apache.org/jira/browse/FLINK-16955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-16955: - Summary: Bump Zookeeper 3.4.X to 3.4.14 (was: Bump Zookeeper to 3.4.14) > Bump

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#discussion_r402813477 ## File path:

[GitHub] [flink] dawidwys commented on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

dawidwys commented on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-608293818 Hi @carp84, 1. The affected ctor's of

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#discussion_r402811540 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402811882 ## File path:

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#discussion_r402811264 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration

flinkbot edited a comment on issue #11622: [FLINK-16913][configuration, statebackend] Migrated StateBackends to use ReadableConfig instead of Configuration URL: https://github.com/apache/flink/pull/11622#issuecomment-607942457 ## CI report: *

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

Jiayi-Liao commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions URL: https://github.com/apache/flink/pull/11567#discussion_r402808759 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11623: [BP-1.10][FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

flinkbot edited a comment on issue #11623: [BP-1.10][FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11623#issuecomment-607962303 ## CI report: * 969feea996071580300b41eb62d2aa4ef47ffbe5 Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint

flinkbot edited a comment on issue #11507: [FLINK-16587] Add basic CheckpointBarrierHandler for unaligned checkpoint URL: https://github.com/apache/flink/pull/11507#issuecomment-603776093 ## CI report: * dee2b337e5e72d8f7b1f5098b74f2958d000fb3c UNKNOWN *

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#discussion_r402807556 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval

flinkbot edited a comment on issue #11473: [FLINK-16705] Ensure MiniCluster shutdown does not interfere with JobResult retrieval URL: https://github.com/apache/flink/pull/11473#issuecomment-602047938 ## CI report: * 93a7b2e30825316151be2f51c2126dc6b6051b66 UNKNOWN *

[jira] [Commented] (FLINK-16636) TableEnvironmentITCase is crashing on Travis

[ https://issues.apache.org/jira/browse/FLINK-16636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074384#comment-17074384 ] Piotr Nowojski commented on FLINK-16636: another instance

[GitHub] [flink] HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism

HuangZhenQiu commented on a change in pull request #11541: [FLINK-15416][network] add task manager netty client retry mechenism URL: https://github.com/apache/flink/pull/11541#discussion_r402807230 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402805950 ## File path:

[GitHub] [flink] gwshawsh commented on issue #8717: fix issue https://issues.apache.org/jira/browse/FLINK-12725

gwshawsh commented on issue #8717: fix issue https://issues.apache.org/jira/browse/FLINK-12725 URL: https://github.com/apache/flink/pull/8717#issuecomment-608290001 @HenryCaiHaiying flink-conf.yml ->classloader.resolve-order: parent-first

[GitHub] [flink] docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner

docete commented on a change in pull request #11276: [FLINK-16029][table-planner-blink] Remove register source and sink in test cases of blink planner URL: https://github.com/apache/flink/pull/11276#discussion_r402805890 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402805658 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402804880 ## File path:

[jira] [Commented] (FLINK-16632) Cast string to timestamp fail

[ https://issues.apache.org/jira/browse/FLINK-16632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074380#comment-17074380 ] 吴彦祖 commented on FLINK-16632: - !image-2020-04-03-15-39-35-702.png! I found a bug related to this one,

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402803918 ## File path:

[GitHub] [flink-statefun] igalshilman commented on issue #94: [FLINK-16950][docs] Add Isolation level to

igalshilman commented on issue #94: [FLINK-16950][docs] Add Isolation level to URL: https://github.com/apache/flink-statefun/pull/94#issuecomment-608288267 When I added the docker-compose exec command originally I wasn’t aware that it does dirty reads by default otherwise I would have

[GitHub] [flink] wangyang0918 commented on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable

wangyang0918 commented on issue #11619: [FLINK-16921][e2e] Make Kubernetes e2e test stable URL: https://github.com/apache/flink/pull/11619#issuecomment-608287863 @rmetzger It seems that the azure pipeline is cancelled by timeout(4h). The two Kubernetes related tests could always pass in

[jira] [Comment Edited] (FLINK-16954) ClassRelocator uses JDK 11 APIs

[ https://issues.apache.org/jira/browse/FLINK-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074375#comment-17074375 ] Tzu-Li (Gordon) Tai edited comment on FLINK-16954 at 4/3/20, 7:55 AM:

[GitHub] [flink-statefun] igalshilman commented on issue #94: [FLINK-16950][docs] Add Isolation level to

igalshilman commented on issue #94: [FLINK-16950][docs] Add Isolation level to URL: https://github.com/apache/flink-statefun/pull/94#issuecomment-608287785 It is very likely that users would use that example to explore forward, and enable check pointing. In that case without isolation

[jira] [Comment Edited] (FLINK-16954) ClassRelocator uses JDK 11 APIs

[ https://issues.apache.org/jira/browse/FLINK-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074375#comment-17074375 ] Tzu-Li (Gordon) Tai edited comment on FLINK-16954 at 4/3/20, 7:54 AM:

[jira] [Commented] (FLINK-16954) ClassRelocator uses JDK 11 APIs

[ https://issues.apache.org/jira/browse/FLINK-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074375#comment-17074375 ] Tzu-Li (Gordon) Tai commented on FLINK-16954: - That was actually the reason why the new

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402799364 ## File path:

[jira] [Commented] (FLINK-16954) ClassRelocator uses JDK 11 APIs

[ https://issues.apache.org/jira/browse/FLINK-16954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074363#comment-17074363 ] Aljoscha Krettek commented on FLINK-16954: -- It seems we need the {{asm-commons}} package which

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402798154 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero

zhijiangW commented on a change in pull request #11351: [FLINK-16404][runtime] Solve the potential deadlock problem when reducing exclusive buffers to zero URL: https://github.com/apache/flink/pull/11351#discussion_r402795100 ## File path:

[jira] [Created] (FLINK-16960) Add PipelinedRegion Interface to Topology

Gary Yao created FLINK-16960: Summary: Add PipelinedRegion Interface to Topology Key: FLINK-16960 URL: https://issues.apache.org/jira/browse/FLINK-16960 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-16430) Pipelined Region Scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-16430: - Summary: Pipelined Region Scheduling (was: Pipelined region scheduling) > Pipelined Region Scheduling

[jira] [Updated] (FLINK-16430) Pipelined region scheduling

[ https://issues.apache.org/jira/browse/FLINK-16430?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Yao updated FLINK-16430: - Issue Type: New Feature (was: Task) > Pipelined region scheduling > --- > >

<    1   2   3   4   5   >