[GitHub] [flink] curcur commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508234412 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartitionView.java ## @@ -0,0 +1,48 @@ +/*

[jira] [Updated] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

[ https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19699: Priority: Critical (was: Major) > PrometheusReporterEndToEndITCase crashes with exit code 143 >

[jira] [Commented] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

[ https://issues.apache.org/jira/browse/FLINK-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217330#comment-17217330 ] Dian Fu commented on FLINK-18836: - Merged to release-1.11 via 515e1f3cb0995feb9218fcb3abafcf77257cab78

[GitHub] [flink] dianfu closed pull request #13695: [FLINK-18836][python] Support Python UDTF return types which are not generator

dianfu closed pull request #13695: URL: https://github.com/apache/flink/pull/13695 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] dianfu commented on pull request #13695: [FLINK-18836][python] Support Python UDTF return types which are not generator

dianfu commented on pull request #13695: URL: https://github.com/apache/flink/pull/13695#issuecomment-712628172 closed via 515e1f3cb0995feb9218fcb3abafcf77257cab78 This is an automated message from the Apache Git Service. To

[GitHub] [flink] leonardBang commented on pull request #13616: [FLINK-18570][hbase][WIP] SQLClientHBaseITCase.testHBase fails on azure

leonardBang commented on pull request #13616: URL: https://github.com/apache/flink/pull/13616#issuecomment-712628111 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217344#comment-17217344 ] Robert Metzger commented on FLINK-19728: [~xintongsong] can you take a look at this issue or

[jira] [Commented] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217345#comment-17217345 ] Zhijiang commented on FLINK-16051: -- [~wind_ljy], do you think we can close this issue for cleanup now,

[GitHub] [flink] curcur commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508250129 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,105 @@ +/* +

[jira] [Created] (FLINK-19730) Create the CoFeedbackTransformation translator

Kostas Kloudas created FLINK-19730: -- Summary: Create the CoFeedbackTransformation translator Key: FLINK-19730 URL: https://issues.apache.org/jira/browse/FLINK-19730 Project: Flink Issue

[jira] [Commented] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217367#comment-17217367 ] Leonard Xu commented on FLINK-19635: Sure, I'll have a look >

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217368#comment-17217368 ] Leonard Xu commented on FLINK-19436: Sure, I'll have a look:) > TPC-DS end-to-end test (Blink

[jira] [Commented] (FLINK-16051) Subtask ID in Overview-Subtasks should start from 1

[ https://issues.apache.org/jira/browse/FLINK-16051?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217369#comment-17217369 ] Jiayi Liao commented on FLINK-16051: [~zjwang] This is reported by a user recently, I've linked the

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217376#comment-17217376 ] Xintong Song commented on FLINK-19728: -- Sure. I'll look into this. > YARN tests failed with "RM

[jira] [Assigned] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xintong Song reassigned FLINK-19728: Assignee: Xintong Song > YARN tests failed with "RM uses DefaultResourceCalculator which

[GitHub] [flink] flinkbot edited a comment on pull request #13693: [Hotfix][Connector-hive] Fix the banned dependency of "_2.10" for sca…

flinkbot edited a comment on pull request #13693: URL: https://github.com/apache/flink/pull/13693#issuecomment-712561061 ## CI report: * 9ca6467a520659322fd91e1a4602f8556bd444f4 Azure:

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508262147 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13616: [FLINK-18570][hbase][WIP] SQLClientHBaseITCase.testHBase fails on azure

flinkbot edited a comment on pull request #13616: URL: https://github.com/apache/flink/pull/13616#issuecomment-707722760 ## CI report: * be3a69f7f525c963887a9cd0e8e293b9fe5062c9 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13678: [FLINK-19586] Add stream committer operators for new Sink API

flinkbot edited a comment on pull request #13678: URL: https://github.com/apache/flink/pull/13678#issuecomment-711439155 ## CI report: * 4873fb92710324b9d47682dcdfb707815d71bfc3 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13684: [FLINK-19707][table-runtime] Refactor table streaming file sink

flinkbot edited a comment on pull request #13684: URL: https://github.com/apache/flink/pull/13684#issuecomment-711859397 ## CI report: * 89cb7caace1af59acf545fb38d275020da6fe523 Azure:

[jira] [Comment Edited] (FLINK-19692) Can't restore feedback channel from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217384#comment-17217384 ] Antti Kaikkonen edited comment on FLINK-19692 at 10/20/20, 7:34 AM:

[GitHub] [flink] flinkbot commented on pull request #13697: [FLINK-19357][FLINK-19357][fs-connector] Introduce createBucketWriter to BucketsBuilder & Introduce FileLifeCycleListener to Buckets

flinkbot commented on pull request #13697: URL: https://github.com/apache/flink/pull/13697#issuecomment-712662619 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 use this comment to track the

[jira] [Assigned] (FLINK-19356) Introduce FileLifeCycleListener to Buckets

[ https://issues.apache.org/jira/browse/FLINK-19356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-19356: Assignee: Jingsong Lee > Introduce FileLifeCycleListener to Buckets >

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217420#comment-17217420 ] Arvid Heise commented on FLINK-19589: - Hi [~Padarn], thank you for the ideas. I like option 1) much

[GitHub] [flink] SteNicholas removed a comment on pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

SteNicholas removed a comment on pull request #13676: URL: https://github.com/apache/flink/pull/13676#issuecomment-712553220 > I had a preliminary review. Overall this looks good but I had some comments on the API. @aljoscha thanks for your preliminary review. I have already replied

[jira] [Updated] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-19728: --- Labels: pull-request-available test-stability (was: test-stability) > YARN tests failed

[GitHub] [flink] rmetzger commented on a change in pull request #13574: [FLINK-18323] Add a Kafka source implementation based on FLIP-27.

rmetzger commented on a change in pull request #13574: URL: https://github.com/apache/flink/pull/13574#discussion_r508332498 ## File path: flink-connectors/flink-connector-kafka/pom.xml ## @@ -101,6 +101,13 @@ under the License. true

[jira] [Created] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent

Huang Xingbo created FLINK-19733: Summary: Make fast_operation and slow_operation produce functions consistent Key: FLINK-19733 URL: https://issues.apache.org/jira/browse/FLINK-19733 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #13692: [FLINK-19624][table-planner-blink] Update deadlock break-up algorithm to cover more cases

flinkbot edited a comment on pull request #13692: URL: https://github.com/apache/flink/pull/13692#issuecomment-712551159 ## CI report: * a43126b85a2068c5605a804b5c46d5c3e669dbbd Azure:

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217455#comment-17217455 ] Dian Fu commented on FLINK-19483: - cc [~hxbks2ks] Could you help to take a look at this issue? >

[jira] [Comment Edited] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217420#comment-17217420 ] Arvid Heise edited comment on FLINK-19589 at 10/20/20, 8:52 AM: Hi

[GitHub] [flink] kl0u commented on pull request #13699: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary

kl0u commented on pull request #13699: URL: https://github.com/apache/flink/pull/13699#issuecomment-712715009 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] rkhachatryan commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

rkhachatryan commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508348714 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartitionView.java ## @@ -0,0 +1,48

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217458#comment-17217458 ] Huang Xingbo commented on FLINK-19483: -- I will take a look soon. > PyFlink Table end-to-end test

[GitHub] [flink] flinkbot edited a comment on pull request #13692: [FLINK-19624][table-planner-blink] Update deadlock break-up algorithm to cover more cases

flinkbot edited a comment on pull request #13692: URL: https://github.com/apache/flink/pull/13692#issuecomment-712551159 ## CI report: * a43126b85a2068c5605a804b5c46d5c3e669dbbd Azure:

[GitHub] [flink] lirui-apache commented on a change in pull request #13684: [FLINK-19707][table-runtime] Refactor table streaming file sink

lirui-apache commented on a change in pull request #13684: URL: https://github.com/apache/flink/pull/13684#discussion_r508190468 ## File path: flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/filesystem/stream/StreamingSink.java ## @@ -0,0 +1,78 @@

[GitHub] [flink] flinkbot edited a comment on pull request #13694: [FLINK-19720][table-api] Introduce new Providers and parallelism API

flinkbot edited a comment on pull request #13694: URL: https://github.com/apache/flink/pull/13694#issuecomment-712569945 ## CI report: * c92d927517014392d271509620f48ad81a1ffc5e Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13696: [FLINK-19726][table] Implement new providers for blink planner

flinkbot edited a comment on pull request #13696: URL: https://github.com/apache/flink/pull/13696#issuecomment-712617122 ## CI report: * dad3de0291d32afee24e9a91edfedb132d6f211f Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #13680: [FLINK-19553] [ Runtime / Web Frontend] The format of checkpoint Completion Time and Failure Time should be changed from HH:mm:ss to

flinkbot edited a comment on pull request #13680: URL: https://github.com/apache/flink/pull/13680#issuecomment-711592132 ## CI report: * f9085414f0bcc7644d623260bdf50758046f95fd Azure:

[jira] [Updated] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang updated FLINK-15981: - Fix Version/s: 1.12.0 > Control the direct memory in FileChannelBoundedData.FileBufferReader >

[GitHub] [flink] curcur commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508248106 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultPartitionFactory.java ## @@ -130,8 +132,15 @@ public

[jira] [Closed] (FLINK-10284) TumblingEventTimeWindows's offset should can be less than zero.

[ https://issues.apache.org/jira/browse/FLINK-10284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiayi Liao closed FLINK-10284. -- Resolution: Fixed Close this since this is already fixed in another JIRA issue. >

[jira] [Commented] (FLINK-19506) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointOnNonParallelLocalChannel: "Exceeded checkpoint tolerable failure threshold"

[ https://issues.apache.org/jira/browse/FLINK-19506?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217359#comment-17217359 ] Robert Metzger commented on FLINK-19506: [~AHeise] can you take a look at this ticket? >

[jira] [Closed] (FLINK-7315) use flink's buffers in netty

[ https://issues.apache.org/jira/browse/FLINK-7315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-7315. --- Resolution: Fixed > use flink's buffers in netty > > > Key:

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508262147 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508264197 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@

[GitHub] [flink] aljoscha commented on pull request #13554: [FLINK-19493] In CliFrontend, make flow of Configuration more obvious

aljoscha commented on pull request #13554: URL: https://github.com/apache/flink/pull/13554#issuecomment-712652388 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message,

[GitHub] [flink] curcur commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

curcur commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508268432 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/BufferWritingResultPartition.java ## @@ -211,46 +223,83 @@

[GitHub] [flink] aljoscha commented on a change in pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

aljoscha commented on a change in pull request #13676: URL: https://github.com/apache/flink/pull/13676#discussion_r508277562 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/CEP.java ## @@ -52,7 +52,48 @@ DataStream input,

[jira] [Created] (FLINK-19732) Disable Checkpointing when in BATCH mode

Kostas Kloudas created FLINK-19732: -- Summary: Disable Checkpointing when in BATCH mode Key: FLINK-19732 URL: https://issues.apache.org/jira/browse/FLINK-19732 Project: Flink Issue Type:

[GitHub] [flink] carp84 commented on pull request #13688: Arena block size sanity

carp84 commented on pull request #13688: URL: https://github.com/apache/flink/pull/13688#issuecomment-712666788 Thanks for continue working on this one @anonymouscodeholic . Checking the Azure test failure it's caused by FLINK-19619 and not related to changes here. I will review the

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217408#comment-17217408 ] Xintong Song commented on FLINK-19728: -- I think this is introduced by FLINK-19689. The added

[GitHub] [flink] SteNicholas commented on a change in pull request #13676: [FLINK-19326][cep] Allow explicitly configuring time behaviour on CEP PatternStream

SteNicholas commented on a change in pull request #13676: URL: https://github.com/apache/flink/pull/13676#discussion_r508292895 ## File path: flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/CEP.java ## @@ -52,7 +52,48 @@ DataStream input,

[jira] [Commented] (FLINK-19731) 使用了批量执行SQL的api，job执行的时候，DataStream 不触发

[ https://issues.apache.org/jira/browse/FLINK-19731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217448#comment-17217448 ] Robert Metzger commented on FLINK-19731: Thank you for opening a ticket. I decreased the

[GitHub] [flink] xintongsong commented on a change in pull request #13644: [FLINK-19542][k8s]Implement LeaderElectionService and LeaderRetrievalService based on Kubernetes API

xintongsong commented on a change in pull request #13644: URL: https://github.com/apache/flink/pull/13644#discussion_r508335109 ## File path: flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/FlinkKubeClient.java ## @@ -104,6 +107,67 @@ KubernetesWatch

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217438#comment-17217438 ] Robert Metzger commented on FLINK-19589: I was wondering if we could introduce a callback that

[GitHub] [flink] wuchong merged pull request #13679: [FLINK-19695][table-runtime-blink] Fix ClassCastException when writing table with rowtime attribute

wuchong merged pull request #13679: URL: https://github.com/apache/flink/pull/13679 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[jira] [Commented] (FLINK-19695) Writing Table with RowTime Column of type TIMESTAMP(3) to Kafka fails with ClassCastException

[ https://issues.apache.org/jira/browse/FLINK-19695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217443#comment-17217443 ] Jark Wu commented on FLINK-19695: - Fixed in - master: 16f97fbfeb822b8f4d9db237dd37bd422812053f -

[GitHub] [flink] flinkbot commented on pull request #13700: [FLINK-19728][yarn][test] Revert FLINK-19689 and disable related test cases.

flinkbot commented on pull request #13700: URL: https://github.com/apache/flink/pull/13700#issuecomment-712722297 ## CI report: * e17173c86ee3418648ac999bab42b33f7ff719ff UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] curcur commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508235769 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java ## @@ -259,9 +260,10 @@

[jira] [Commented] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217322#comment-17217322 ] Dian Fu commented on FLINK-19436: -

[jira] [Updated] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19436: Priority: Critical (was: Major) > TPC-DS end-to-end test (Blink planner) failed during shutdown >

[jira] [Commented] (FLINK-19699) PrometheusReporterEndToEndITCase crashes with exit code 143

[ https://issues.apache.org/jira/browse/FLINK-19699?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217325#comment-17217325 ] Dian Fu commented on FLINK-19699: -

[jira] [Commented] (FLINK-18427) Job failed under java 11

[ https://issues.apache.org/jira/browse/FLINK-18427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217331#comment-17217331 ] Zhijiang commented on FLINK-18427: -- [~xintongsong] might be more familiar with the concerns of memory

[jira] [Commented] (FLINK-19692) Can't restore feedback channel from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217336#comment-17217336 ] Igal Shilman commented on FLINK-19692: -- Thanks for following up, we are investigating this and

[jira] [Assigned] (FLINK-15981) Control the direct memory in FileChannelBoundedData.FileBufferReader

[ https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang reassigned FLINK-15981: Assignee: Zhijiang > Control the direct memory in FileChannelBoundedData.FileBufferReader >

[jira] [Closed] (FLINK-19368) TableEnvHiveConnectorITCase fails with Hive-3.x

[ https://issues.apache.org/jira/browse/FLINK-19368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-19368. Resolution: Fixed master: eb6d6f3981c9913a4520dca3f870223fcef03350 > TableEnvHiveConnectorITCase

[jira] [Comment Edited] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217343#comment-17217343 ] Zhijiang edited comment on FLINK-19249 at 10/20/20, 6:50 AM: - I dig out the

[jira] [Commented] (FLINK-19249) Detect broken connections in case TCP Timeout takes too long.

[ https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217343#comment-17217343 ] Zhijiang commented on FLINK-19249: -- I dig out the previously discussed issues

[GitHub] [flink] flinkbot edited a comment on pull request #13616: [FLINK-18570][hbase][WIP] SQLClientHBaseITCase.testHBase fails on azure

flinkbot edited a comment on pull request #13616: URL: https://github.com/apache/flink/pull/13616#issuecomment-707722760 ## CI report: * be3a69f7f525c963887a9cd0e8e293b9fe5062c9 Azure:

[GitHub] [flink] curcur commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508249209 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,105 @@ +/* +

[jira] [Closed] (FLINK-19422) Avro Confluent Schema Registry nightly end-to-end test failed with "Register operation timed out; error code: 50002"

[ https://issues.apache.org/jira/browse/FLINK-19422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger closed FLINK-19422. -- Resolution: Fixed Closing as fixed for now. > Avro Confluent Schema Registry nightly

[jira] [Commented] (FLINK-19594) SubTasks start index don't unified and may confuse users

[ https://issues.apache.org/jira/browse/FLINK-19594?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217372#comment-17217372 ] Jiayi Liao commented on FLINK-19594: Link an duplicated issue reported earlier. 

[jira] [Assigned] (FLINK-19635) HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result mismatch

[ https://issues.apache.org/jira/browse/FLINK-19635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19635: --- Assignee: Leonard Xu > HBaseConnectorITCase.testTableSourceSinkWithDDL is unstable with a result

[jira] [Assigned] (FLINK-19436) TPC-DS end-to-end test (Blink planner) failed during shutdown

[ https://issues.apache.org/jira/browse/FLINK-19436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-19436: --- Assignee: Leonard Xu > TPC-DS end-to-end test (Blink planner) failed during shutdown >

[jira] [Created] (FLINK-19731) 使用了批量执行SQL的api，job执行的时候，DataStream 不触发

little-tomato created FLINK-19731: - Summary: 使用了批量执行SQL的api，job执行的时候，DataStream 不触发 Key: FLINK-19731 URL: https://issues.apache.org/jira/browse/FLINK-19731 Project: Flink Issue Type: Bug

[GitHub] [flink] carp84 closed pull request #13393: [FLINK-19238] [RocksDB] Sanity check for arena block size

carp84 closed pull request #13393: URL: https://github.com/apache/flink/pull/13393 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] carp84 commented on pull request #13393: [FLINK-19238] [RocksDB] Sanity check for arena block size

carp84 commented on pull request #13393: URL: https://github.com/apache/flink/pull/13393#issuecomment-712655399 > > I (previously @juha-mynttinen-king) switched over to this account. I think we can keep this PR, if that's fine for you @carp84. > > Actually, it didn't work out. I

[jira] [Closed] (FLINK-19268) Introduce batch-style execution for bounded keyed streams

[ https://issues.apache.org/jira/browse/FLINK-19268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek closed FLINK-19268. Resolution: Implemented All subtasks are done. > Introduce batch-style execution for

[jira] [Comment Edited] (FLINK-19692) Can't restore feedback channel from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217384#comment-17217384 ] Antti Kaikkonen edited comment on FLINK-19692 at 10/20/20, 7:32 AM:

[jira] [Comment Edited] (FLINK-19692) Can't restore feedback channel from savepoint

[ https://issues.apache.org/jira/browse/FLINK-19692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217384#comment-17217384 ] Antti Kaikkonen edited comment on FLINK-19692 at 10/20/20, 7:31 AM:

[GitHub] [flink] pnowojski commented on a change in pull request #13614: [FLINK-19547][runtime] Clean up partial record when reconnecting for Approximate Local Recovery

pnowojski commented on a change in pull request #13614: URL: https://github.com/apache/flink/pull/13614#discussion_r508271579 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/ResultPartitionTest.java ## @@ -526,6 +526,44 @@ public void

[GitHub] [flink] flinkbot edited a comment on pull request #13653: [FLINK-17528][table] Remove RowData#get() and ArrayData#get() and use FieldGetter and ElementGetter instead

flinkbot edited a comment on pull request #13653: URL: https://github.com/apache/flink/pull/13653#issuecomment-709337488 ## CI report: * a8432b0e26a5ba02b49f26a34f3f667df6808856 Azure:

[jira] [Assigned] (FLINK-19316) FLIP-134: Batch execution for the DataStream API

[ https://issues.apache.org/jira/browse/FLINK-19316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kostas Kloudas reassigned FLINK-19316: -- Assignee: Kostas Kloudas > FLIP-134: Batch execution for the DataStream API >

[GitHub] [flink] flinkbot commented on pull request #13698: [FLINK-19732] Disable checkpointing in BATCH mode

flinkbot commented on pull request #13698: URL: https://github.com/apache/flink/pull/13698#issuecomment-712664579 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 use this comment to track the

[jira] [Commented] (FLINK-19700) Make Kubernetes Client in KubernetesResourceManagerDriver use io executor

[ https://issues.apache.org/jira/browse/FLINK-19700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217403#comment-17217403 ] Xintong Song commented on FLINK-19700: -- [~nicholasjiang] Sure, I've assigned you. Please go ahead.

[GitHub] [flink] flinkbot edited a comment on pull request #13554: [FLINK-19493] In CliFrontend, make flow of Configuration more obvious

flinkbot edited a comment on pull request #13554: URL: https://github.com/apache/flink/pull/13554#issuecomment-704950126 ## CI report: * Unknown: [CANCELED](TBD) * ef47deeb469f6a6ad53287f787a23baacba3622b Azure:

[jira] [Commented] (FLINK-19469) HBase connector 2.2 failed to download dependencies "org.glassfish:javax.el:jar:3.0.1-b06-SNAPSHOT"

[ https://issues.apache.org/jira/browse/FLINK-19469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217415#comment-17217415 ] Robert Metzger commented on FLINK-19469: Mh, why is this still failing on master?

[GitHub] [flink] azagrebin commented on a change in pull request #13547: [FLINK-14406][runtime] Exposes managed memory usage through the REST API

azagrebin commented on a change in pull request #13547: URL: https://github.com/apache/flink/pull/13547#discussion_r508297589 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/slot/TaskSlotTable.java ## @@ -199,10 +208,11 @@ default int

[jira] [Commented] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217422#comment-17217422 ] Robert Metzger commented on FLINK-19728: I agree with your proposed resolution! > YARN tests

[jira] [Updated] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent

[ https://issues.apache.org/jira/browse/FLINK-19733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-19733: - Issue Type: Improvement (was: New Feature) > Make fast_operation and slow_operation produce

[GitHub] [flink] gm7y8 commented on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

gm7y8 commented on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-712711411 @XComp I was able to identify the code fix. I working to unit test it had some issue with Flink set up to start a job with checkpoint and savepoint. it might take a day or so as

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

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

[GitHub] [flink] flinkbot edited a comment on pull request #13458: FLINK-18851 [runtime] Add checkpoint type to checkpoint history entries in Web UI

flinkbot edited a comment on pull request #13458: URL: https://github.com/apache/flink/pull/13458#issuecomment-697041219 ## CI report: * 3a9c127acf7d5615f5a32c7af35f8611b93cd6ab Azure:

[GitHub] [flink] flinkbot commented on pull request #13699: [FLINK-19154] ApplicationDispatcherBootstrap clean up HA data only when necessary

flinkbot commented on pull request #13699: URL: https://github.com/apache/flink/pull/13699#issuecomment-712700391 ## CI report: * 30c315c3eed0e0f32ceb06d3f7c64375c54c5014 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] rkhachatryan commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

rkhachatryan commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508345496 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,105 @@

[GitHub] [flink] curcur commented on a change in pull request #13648: [FLINK-19632] Introduce a new ResultPartitionType for Approximate Local Recovery

curcur commented on a change in pull request #13648: URL: https://github.com/apache/flink/pull/13648#discussion_r508236580 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedApproximateSubpartition.java ## @@ -0,0 +1,105 @@ +/* +

[jira] [Created] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

Dian Fu created FLINK-19728: --- Summary: YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified" Key: FLINK-19728 URL:

[jira] [Updated] (FLINK-19728) YARN tests failed with "RM uses DefaultResourceCalculator which used only memory as resource-type but invalid resource-types specified"

[ https://issues.apache.org/jira/browse/FLINK-19728?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-19728: Labels: test-stability (was: ) > YARN tests failed with "RM uses DefaultResourceCalculator which used

[GitHub] [flink] JingsongLi merged pull request #13624: [FLINK-19368][hive] TableEnvHiveConnectorITCase fails with Hive-3.x

JingsongLi merged pull request #13624: URL: https://github.com/apache/flink/pull/13624 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

  1   2   3   4   5   6   >