xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476975877
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,301 @@
+/*
+ * Licensed
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476988674
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,301 @@
+/*
+ * Licensed
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476996403
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,301 @@
+/*
+ * Licensed
flinkbot commented on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680478070
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
zhijiangW commented on a change in pull request #2:
URL: https://github.com/apache/flink-benchmarks/pull/2#discussion_r477009866
##
File path:
src/main/java/org/apache/flink/benchmark/RemoteChannelThroughputBenchmark.java
##
@@ -80,6 +84,7 @@ public void
flinkbot edited a comment on pull request #13244:
URL: https://github.com/apache/flink/pull/13244#issuecomment-680535784
## CI report:
* f5fee133d28436ab73b03d05b1f6fadc8648f5d0 Azure:
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 40658a82560ebc79ee2047a789db4fa003115099 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184918#comment-17184918
]
Rui Li commented on FLINK-19025:
Hey [~McClone], are you writing streaming data into hive orc table? If
flinkbot edited a comment on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680489296
## CI report:
* 7abb7dec5769d7d9569b17de97c477c989f67ed2 Azure:
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-18333:
---
Labels: pull-request-available test-stability (was: test-stability)
>
leonardBang opened a new pull request #13244:
URL: https://github.com/apache/flink/pull/13244
## What is the purpose of the change
* This pull request fix up unstable test UnsignedTypeConversionITCase.
## Brief change log
- Avoid using MariaDB4jRule to create a DB
flinkbot commented on pull request #13244:
URL: https://github.com/apache/flink/pull/13244#issuecomment-680535784
## CI report:
* f5fee133d28436ab73b03d05b1f6fadc8648f5d0 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184947#comment-17184947
]
Rui Li commented on FLINK-19025:
[~McClone] The stacktrace indicates you're writing streaming data.
klion26 commented on a change in pull request #13212:
URL: https://github.com/apache/flink/pull/13212#discussion_r477046283
##
File path: docs/monitoring/historyserver.zh.md
##
@@ -22,62 +22,67 @@ specific language governing permissions and limitations
under the License.
-->
[
https://issues.apache.org/jira/browse/FLINK-11712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
godfrey he closed FLINK-11712.
--
Resolution: Resolved
> Add cost model for both batch and streaming
>
zhijiangW commented on a change in pull request #2:
URL: https://github.com/apache/flink-benchmarks/pull/2#discussion_r477008616
##
File path:
src/main/java/org/apache/flink/benchmark/RemoteChannelThroughputBenchmark.java
##
@@ -48,6 +49,9 @@
private MiniCluster
flinkbot edited a comment on pull request #13186:
URL: https://github.com/apache/flink/pull/13186#issuecomment-675299227
## CI report:
* 63c2f658cc309661c434451a5d8c0b38d2e748d3 Azure:
flinkbot commented on pull request #13243:
URL: https://github.com/apache/flink/pull/13243#issuecomment-680489296
## CI report:
* 7abb7dec5769d7d9569b17de97c477c989f67ed2 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
flinkbot commented on pull request #13244:
URL: https://github.com/apache/flink/pull/13244#issuecomment-680526208
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
zhuxiaoshang commented on a change in pull request #13225:
URL: https://github.com/apache/flink/pull/13225#discussion_r477020865
##
File path: docs/dev/user_defined_functions.zh.md
##
@@ -147,95 +142,75 @@ data.map (new RichMapFunction[String, Int] {
-Rich functions
zhuxiaoshang commented on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-680556966
Thanks for your review @RocMarshal.I have made some changes according to
your suggestions.
This is an
[
https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184921#comment-17184921
]
tartarus commented on FLINK-19022:
--
[~trohrmann] I want to confirm the little details.
we pass a
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 40658a82560ebc79ee2047a789db4fa003115099 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17184946#comment-17184946
]
McClone commented on FLINK-19025:
-
Exception in thread "main" java.lang.NoClassDefFoundError:
billyrrr commented on pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#issuecomment-680671983
Hi, @carp84 Thank you for the review.
I think that "stateful functions" should be translated to chinese to promote
communications within people who primarily speak
flinkbot edited a comment on pull request #13225:
URL: https://github.com/apache/flink/pull/13225#issuecomment-678953566
## CI report:
* 6bfd27b44774c770a2d28ee9ca1bde0e11bfbe29 Azure:
[
https://issues.apache.org/jira/browse/FLINK-19022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183768#comment-17183768
]
Till Rohrmann commented on FLINK-19022:
---
Yes, for 3) we also need to pass a {{FatalErrorHandler}}
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee reopened FLINK-17397:
--
> Support processing-time temporal join with filesystem source
>
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183842#comment-17183842
]
Jingsong Lee commented on FLINK-17397:
--
[~jark] Sounds good to me.
> Support processing-time
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17397:
-
Summary: Support processing-time temporal join with filesystem source
(was:
[
https://issues.apache.org/jira/browse/FLINK-19043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Roc Marshal updated FLINK-19043:
Description:
The page url is :
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17397:
-
Labels: (was: starter)
> Support processing-time temporal join with filesystem source
>
aljoscha opened a new pull request #13237:
URL: https://github.com/apache/flink/pull/13237
## What is the purpose of the change
Before, it could happen that the embedded node is not ready. Now we set
a restart strategy and enable checkpointing for the test job to allow it
to
dawidwys merged pull request #13050:
URL: https://github.com/apache/flink/pull/13050
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
dawidwys commented on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-679895722
Thanks for the update. LGTM
This is an automated message from the Apache Git Service.
To respond to the
aljoscha commented on pull request #13237:
URL: https://github.com/apache/flink/pull/13237#issuecomment-679905968
I changed the PR to instead wait for liveness of the cluster.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
badqiu updated FLINK-19048:
---
Summary: support line format for table connector (was: suuport line format
for table connector)
> support
lirui-apache opened a new pull request #13238:
URL: https://github.com/apache/flink/pull/13238
…e::testNonPartitionStreamingSource
## What is the purpose of the change
Fix hive table source test failures when object reuse is enabled.
## Brief change log
Robert Metzger created FLINK-19049:
--
Summary: TableEnvironmentImpl.executeInternal() does not wait for
the final job status
Key: FLINK-19049
URL: https://issues.apache.org/jira/browse/FLINK-19049
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183820#comment-17183820
]
Leonard Xu commented on FLINK-18333:
[~jark]
Thanks for the reminder, I'll open the PR soon.
>
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183821#comment-17183821
]
Aljoscha Krettek commented on FLINK-18959:
--
Yes, exactly. The cluster should shut down in both
zentol commented on pull request #13228:
URL: https://github.com/apache/flink/pull/13228#issuecomment-679861273
CI shows a timeout in {{DataSinkTaskTest.testDataSinkTask}}.
This is an automated message from the Apache Git
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183829#comment-17183829
]
Jingsong Lee commented on FLINK-17397:
--
Consider {{LookupableTableSource}} is not a good candidate
[
https://issues.apache.org/jira/browse/FLINK-19040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-19040.
--
Resolution: Fixed
Merged to master as f666b81e75. Merged to release-1.11 as 89ad9ca93c
>
[
https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Echo Lee updated FLINK-19005:
-
Attachment: heap_dump_echo_lee.tar.xz
> used metaspace grow on every execution
>
[
https://issues.apache.org/jira/browse/FLINK-19025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183902#comment-17183902
]
Rui Li commented on FLINK-19025:
I have tested writing to Hive 2.1.1 ORC tables with hive connector and
[
https://issues.apache.org/jira/browse/FLINK-19021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19021:
---
Labels: pull-request-available (was: )
> Cleanups of the ResultPartition components
>
[
https://issues.apache.org/jira/browse/FLINK-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183922#comment-17183922
]
Benchao Li commented on FLINK-19048:
Is this a duplicate of
flinkbot edited a comment on pull request #13172:
URL: https://github.com/apache/flink/pull/13172#issuecomment-674806621
## CI report:
* 78b0ad2216677f31e8ab3844cb3632dc479591dc Azure:
flinkbot edited a comment on pull request #13227:
URL: https://github.com/apache/flink/pull/13227#issuecomment-679046587
## CI report:
* 213695b1635186819bcde49ed3c94f0238943ee2 Azure:
[
https://issues.apache.org/jira/browse/FLINK-12130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183825#comment-17183825
]
Aljoscha Krettek commented on FLINK-12130:
--
Sure, that would be good!
> Apply command line
[
https://issues.apache.org/jira/browse/FLINK-14435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias reassigned FLINK-14435:
Assignee: Matthias
> Add TaskManageResourceInfo which match the memory compositions of
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17397:
-
Fix Version/s: (was: 1.12.0)
> FileSystemTableFactory supports LookupableTableSource
>
[
https://issues.apache.org/jira/browse/FLINK-17397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-17397.
Resolution: Invalid
> FileSystemTableFactory supports LookupableTableSource
>
Roc Marshal created FLINK-19043:
---
Summary: Translate the page 'Logging' of 'Debugging & Monitoring'
into Chinese
Key: FLINK-19043
URL: https://issues.apache.org/jira/browse/FLINK-19043
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-18592?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183874#comment-17183874
]
Yun Gao commented on FLINK-18592:
-
Hi [~ALVINWJ] [~liyu] How do we plan to fix this issue ? It seems
[
https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183877#comment-17183877
]
Chesnay Schepler commented on FLINK-18192:
--
[~twalthr] Could you find someone to gauge how
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183878#comment-17183878
]
Till Rohrmann commented on FLINK-18959:
---
How would this work [~aljoscha]? If you are deploying a
[
https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183887#comment-17183887
]
Echo Lee commented on FLINK-19005:
--
[~chesnay] Wordcount.jar is not easy to reproduce this issue, but
flinkbot edited a comment on pull request #13237:
URL: https://github.com/apache/flink/pull/13237#issuecomment-679888408
## CI report:
* c129c1364c1e32188593a708bdef954ed7b8cdaa Azure:
badqiu created FLINK-19048:
--
Summary: suuport line format for table connector
Key: FLINK-19048
URL: https://issues.apache.org/jira/browse/FLINK-19048
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183906#comment-17183906
]
Chesnay Schepler commented on FLINK-19005:
--
[~Echo Lee] The JMX thingie is probably fine since
tillrohrmann commented on a change in pull request #13181:
URL: https://github.com/apache/flink/pull/13181#discussion_r476318798
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SchedulerImpl.java
##
@@ -98,14 +101,15 @@ public
flinkbot edited a comment on pull request #13238:
URL: https://github.com/apache/flink/pull/13238#issuecomment-679946137
## CI report:
* e85e2428cac727ca774025ca106d2cb0c319e78e Azure:
flinkbot edited a comment on pull request #13239:
URL: https://github.com/apache/flink/pull/13239#issuecomment-679946229
## CI report:
* af13efd2abeedd3f3d3a7db9e28d6a32456f8e52 Azure:
flinkbot edited a comment on pull request #13237:
URL: https://github.com/apache/flink/pull/13237#issuecomment-679888408
## CI report:
* c129c1364c1e32188593a708bdef954ed7b8cdaa Azure:
[
https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183928#comment-17183928
]
ShenDa edited comment on FLINK-19005 at 8/25/20, 10:58 AM:
---
[~chesnay] I'm
[
https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183931#comment-17183931
]
Robert Metzger commented on FLINK-19012:
flinkbot edited a comment on pull request #13050:
URL: https://github.com/apache/flink/pull/13050#issuecomment-667904442
## CI report:
* 0aa2e599db47cf035f6d7cf0389e7caa273b5880 Azure:
RocMarshal commented on a change in pull request #13172:
URL: https://github.com/apache/flink/pull/13172#discussion_r476208584
##
File path: docs/dev/migration.zh.md
##
@@ -25,18 +25,18 @@ under the License.
* This will be replaced by the TOC
{:toc}
-See the [older
Myracle commented on pull request #13227:
URL: https://github.com/apache/flink/pull/13227#issuecomment-679832482
@flinkbot run azure
This is an automated message from the Apache Git Service.
To respond to the message, please
flinkbot edited a comment on pull request #13172:
URL: https://github.com/apache/flink/pull/13172#issuecomment-674806621
## CI report:
* 78b0ad2216677f31e8ab3844cb3632dc479591dc Azure:
flinkbot edited a comment on pull request #13227:
URL: https://github.com/apache/flink/pull/13227#issuecomment-679046587
## CI report:
* 213695b1635186819bcde49ed3c94f0238943ee2 Azure:
shuiqiangchen opened a new pull request #13236:
URL: https://github.com/apache/flink/pull/13236
## What is the purpose of the change
Fixed the bug that failed to set merged configurations into
DataStreamTwoInputPythonStatelessFunctionOperator when finally generating the
dawidwys commented on pull request #13216:
URL: https://github.com/apache/flink/pull/13216#issuecomment-679855750
Personally I am not convinced this is a good behaviour. I think temporary
tables should use the factory of the catalog they were registered in.
Imo if hive cannot deal
[
https://issues.apache.org/jira/browse/FLINK-19041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-19041:
---
Labels: pull-request-available (was: )
> Add dependency management for ConnectedStream in
[
https://issues.apache.org/jira/browse/FLINK-19009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183816#comment-17183816
]
Chesnay Schepler commented on FLINK-19009:
--
hmm...it is indeed weird that we use
[
https://issues.apache.org/jira/browse/FLINK-18333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183815#comment-17183815
]
Jark Wu commented on FLINK-18333:
-
Hi [~Leonard Xu], what is the status of this issue now?
>
flinkbot commented on pull request #13236:
URL: https://github.com/apache/flink/pull/13236#issuecomment-679860054
## CI report:
* 5ed0da03dffc085997903aa6868e97ea98340433 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476259405
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,325 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183849#comment-17183849
]
Chesnay Schepler commented on FLINK-18695:
--
[~gaoyunhaii] ping
> Allow NettyBufferPool to
flinkbot edited a comment on pull request #13227:
URL: https://github.com/apache/flink/pull/13227#issuecomment-679046587
## CI report:
* 213695b1635186819bcde49ed3c94f0238943ee2 Azure:
flinkbot edited a comment on pull request #13234:
URL: https://github.com/apache/flink/pull/13234#issuecomment-679243226
## CI report:
* e1c13bbc1899c7c2d7e94d26cdeb47deddf76b50 Azure:
[
https://issues.apache.org/jira/browse/FLINK-17273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183869#comment-17183869
]
Xintong Song commented on FLINK-17273:
--
Hi [~felixzheng],
Is there any updates on this ticket?
[
https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18192:
-
Fix Version/s: 1.12.0
> Upgrade to Avro version 1.9.2 from 1.8.2
>
StephanEwen commented on pull request #13034:
URL: https://github.com/apache/flink/pull/13034#issuecomment-679901944
Thanks for fixing this instability.
Some comments from my side:
- It would be nice to have non-alphanumeric characters.
- The retries are okay, but we could
[
https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18192:
-
Affects Version/s: (was: 1.11.0)
> Upgrade to Avro version 1.9.2 from 1.8.2
>
[
https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18192:
-
Labels: (was: Avro avro)
> Upgrade to Avro version 1.9.2 from 1.8.2
>
[
https://issues.apache.org/jira/browse/FLINK-18192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-18192:
-
Component/s: Build System
> Upgrade to Avro version 1.9.2 from 1.8.2
>
[
https://issues.apache.org/jira/browse/FLINK-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183894#comment-17183894
]
Chesnay Schepler commented on FLINK-19005:
--
[~Echo Lee] similar problem, user classloader is
carp84 commented on a change in pull request #131:
URL: https://github.com/apache/flink-statefun/pull/131#discussion_r476234672
##
File path: README.zh.md
##
@@ -0,0 +1,228 @@
+
Review comment:
I'm not quite sure whether translate the name into Chinese is a good
idea.
[
https://issues.apache.org/jira/browse/FLINK-18959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183761#comment-17183761
]
Till Rohrmann commented on FLINK-18959:
---
This is true [~Jiangang]. Was this the requirement you
[
https://issues.apache.org/jira/browse/FLINK-18222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Robert Metzger reassigned FLINK-18222:
--
Assignee: Robert Metzger
> "Avro Confluent Schema Registry nightly end-to-end test"
[
https://issues.apache.org/jira/browse/FLINK-9992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu reassigned FLINK-9992:
--
Assignee: Dian Fu
> FsStorageLocationReferenceTest#testEncodeAndDecode failed in CI
>
rmetzger commented on a change in pull request #12823:
URL: https://github.com/apache/flink/pull/12823#discussion_r476240082
##
File path: flink-hadoop-utils/pom.xml
##
@@ -0,0 +1,78 @@
+
+
+http://maven.apache.org/POM/4.0.0;
+
[
https://issues.apache.org/jira/browse/FLINK-18685?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183813#comment-17183813
]
Robert Metzger commented on FLINK-18685:
Just for the record: Some discussion on this ticket has
xintongsong commented on a change in pull request #13186:
URL: https://github.com/apache/flink/pull/13186#discussion_r476260518
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManagerDriver.java
##
@@ -0,0 +1,325 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-19045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stephan Ewen reassigned FLINK-19045:
Assignee: Stephan Ewen
> Remove obsolete option
>
Stephan Ewen created FLINK-19045:
Summary: Remove obsolete option
'taskmanager.network.partition.force-release-on-consumption'
Key: FLINK-19045
URL: https://issues.apache.org/jira/browse/FLINK-19045
Stephan Ewen created FLINK-19046:
Summary: Introduce separate classes for PipelinedResultPartition
and BoundedBlockingResultPartition
Key: FLINK-19046
URL: https://issues.apache.org/jira/browse/FLINK-19046
1 - 100 of 276 matches
Mail list logo
