Danny Chen created FLINK-17715:
--
Summary: Supports create function in SQL-CLI
Key: FLINK-17715
URL: https://issues.apache.org/jira/browse/FLINK-17715
Project: Flink
Issue Type: New Feature
[
https://issues.apache.org/jira/browse/FLINK-17596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-17596:
Labels: pull-request-available test-stability (was: pull-request-available)
> Unstable
wangyang0918 commented on pull request #11839:
URL: https://github.com/apache/flink/pull/11839#issuecomment-629044350
@zentol I have updated the PR according to the discussion. We will start
with `.log` file by using rolling appender. I think it could meet the most
requirements and leave
[
https://issues.apache.org/jira/browse/FLINK-17596?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-17596.
---
Resolution: Fixed
Merged to master via 282da0dd3e2def9e0ea6693f953d2733eb663e70
> Unstable
hequn8128 commented on pull request #12160:
URL: https://github.com/apache/flink/pull/12160#issuecomment-629043705
@rmetzger Thank you for your help.
This is an automated message from the Apache Git Service.
To respond to
dianfu closed pull request #12092:
URL: https://github.com/apache/flink/pull/12092
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
[
https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107974#comment-17107974
]
Piotr Nowojski commented on FLINK-17706:
I'm ok with relicensing my contributions to the Apache
Zhu Zhu created FLINK-17714:
---
Summary: Support custom RestartBackoffTimeStrategy
Key: FLINK-17714
URL: https://issues.apache.org/jira/browse/FLINK-17714
Project: Flink
Issue Type: Wish
flinkbot edited a comment on pull request #12161:
URL: https://github.com/apache/flink/pull/12161#issuecomment-629011624
## CI report:
* fb208fbfdf55bdde668c609a3305d938b8105f95 Azure:
flinkbot edited a comment on pull request #12157:
URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224
## CI report:
* c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN
* 409246b65de6c5e76e6462ed4a55d73c7dc76c22 Travis:
flinkbot edited a comment on pull request #12112:
URL: https://github.com/apache/flink/pull/12112#issuecomment-627844596
## CI report:
* fabb16cd67f08a76f43a0c3b62d2b48e7b6a6642 Azure:
flinkbot edited a comment on pull request #12150:
URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536
## CI report:
* 5ecc1a2c3a42b5b10f837d5c7a50f76dc31d6a97 Azure:
flinkbot edited a comment on pull request #12143:
URL: https://github.com/apache/flink/pull/12143#issuecomment-628420573
## CI report:
* dcd8b8efec513fcfa4d833ab2915e7171eee6ace Azure:
flinkbot edited a comment on pull request #12108:
URL: https://github.com/apache/flink/pull/12108#issuecomment-627804642
## CI report:
* b16d233a709d1d9794b8ff261dfa598a9d7530d5 Azure:
flinkbot edited a comment on pull request #12069:
URL: https://github.com/apache/flink/pull/12069#issuecomment-626515528
## CI report:
* 731dff0812f1abb16193f7a2fe6f54b3ef65ae2d UNKNOWN
* b90556c18fabe5fcfc3e93ba8c6b6a44b0d21f88 Azure:
zhijiangW commented on a change in pull request #11948:
URL: https://github.com/apache/flink/pull/11948#discussion_r425580357
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/AlternatingCheckpointBarrierHandler.java
##
@@ -0,0 +1,102 @@
KarmaGYZ commented on a change in pull request #11854:
URL: https://github.com/apache/flink/pull/11854#discussion_r425580321
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execution/Environment.java
##
@@ -157,6 +158,13 @@
GlobalAggregateManager
flinkbot edited a comment on pull request #11010:
URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412
## CI report:
* 27818c93f9a8d1f580b96bca10111f0cb95bbb07 Azure:
dianfu commented on pull request #12092:
URL: https://github.com/apache/flink/pull/12092#issuecomment-629041252
Thanks. Merging...
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee closed FLINK-17606.
Resolution: Implemented
master: 91557c83447444ecfbeba3e4c58297908940834a
> Introduce DataGen
[
https://issues.apache.org/jira/browse/FLINK-17606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jingsong Lee updated FLINK-17606:
-
Component/s: Table SQL / API
> Introduce DataGen connector in table
>
JingsongLi merged pull request #12074:
URL: https://github.com/apache/flink/pull/12074
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
WeiZhong94 commented on pull request #12092:
URL: https://github.com/apache/flink/pull/12092#issuecomment-629040680
@dianfu The test has passed in my azure.
https://dev.azure.com/weizhong0618/Flink/_build/results?buildId=101=results
[
https://issues.apache.org/jira/browse/FLINK-17713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-17713.
--
Resolution: Fixed
> "Stateful stream job upgrade end-to-end test" fails
>
[
https://issues.apache.org/jira/browse/FLINK-17467?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reopened FLINK-17467:
Reopened because of FLINK-17713
> Implement aligned savepoint in UC mode
>
KarmaGYZ commented on a change in pull request #11854:
URL: https://github.com/apache/flink/pull/11854#discussion_r425577548
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/execution/Environment.java
##
@@ -157,6 +158,13 @@
GlobalAggregateManager
[
https://issues.apache.org/jira/browse/FLINK-17713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107967#comment-17107967
]
Robert Metzger commented on FLINK-17713:
Reverted in
[
https://issues.apache.org/jira/browse/FLINK-17565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107965#comment-17107965
]
Yang Wang commented on FLINK-17565:
---
Maybe we need to wait for the release of 4.9.2 and then bump the
Robert Metzger created FLINK-17713:
--
Summary: "Stateful stream job upgrade end-to-end test" fails
Key: FLINK-17713
URL: https://issues.apache.org/jira/browse/FLINK-17713
Project: Flink
KarmaGYZ commented on a change in pull request #11854:
URL: https://github.com/apache/flink/pull/11854#discussion_r425575563
##
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/AbstractIterativeTask.java
##
@@ -183,8 +186,9 @@ protected void
TsReaper commented on pull request #12069:
URL: https://github.com/apache/flink/pull/12069#issuecomment-629037091
> CollectSinkOperatorCoordinator
`CollectSinkOperatorCoordinator` is also tested along with the sink function.
[
https://issues.apache.org/jira/browse/FLINK-17416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107960#comment-17107960
]
Yang Wang commented on FLINK-17416:
---
Update on this issue.
After some discussion with author of
rmetzger commented on pull request #12160:
URL: https://github.com/apache/flink/pull/12160#issuecomment-629036740
I don't know what happened there. I manually triggered a build for commit
"be9779df4a817697788ed44fc618900595b248d8" here:
[
https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107958#comment-17107958
]
Hequn Cheng commented on FLINK-17710:
-
Changs were reverted for now on master since the test begins
KurtYoung commented on pull request #12069:
URL: https://github.com/apache/flink/pull/12069#issuecomment-629035731
Still need a multi thread tests for `CollectSinkFunction` to test the case
when buffer is full and block the main thread.
And also need add some tests for
[
https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107957#comment-17107957
]
Hequn Cheng commented on FLINK-17303:
-
Changes were reverted in master due to FLINK-17710 via
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425572456
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/DataStreamSink.java
##
@@ -35,9 +35,9 @@
private
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425571792
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/StreamKafkaShuffleSink.java
##
@@
hequn8128 edited a comment on pull request #12160:
URL: https://github.com/apache/flink/pull/12160#issuecomment-629031753
I have reverted the related commits for safety consideration. The test
begins normally now. I will check more later. Sorry about this.
chaojianok commented on pull request #247:
URL: https://github.com/apache/flink-web/pull/247#issuecomment-629033247
@klion26 Thanks a lot for your review, I've optimized it according to your
suggestions, please help me review again.
tzulitai opened a new pull request #111:
URL: https://github.com/apache/flink-statefun/pull/111
Note that this would not pass as of now, since the Docker image
`flink:1.10.1` probably isn't published yet. We should merge this only after
that is available.
[
https://issues.apache.org/jira/browse/FLINK-17712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-17712:
---
Labels: pull-request-available (was: )
> Upgrade Flink version to 1.10.1 in Stateful
flinkbot edited a comment on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415
## CI report:
* 09465d2623a839311aa67ddfac4059f525f2b62c Azure:
flinkbot edited a comment on pull request #12150:
URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536
## CI report:
* e0e57e5b94fe42e04146af4796431cdc40efc2bb Azure:
flinkbot edited a comment on pull request #12112:
URL: https://github.com/apache/flink/pull/12112#issuecomment-627844596
## CI report:
* caebbb2978136a5c36059cef6dcfde1b97f26456 Azure:
flinkbot edited a comment on pull request #11385:
URL: https://github.com/apache/flink/pull/11385#issuecomment-597956562
## CI report:
* 9e1bbeafa1a4d0f673ebba7f87ef9032253a29f0 UNKNOWN
* 88eb4f91c72b735fe947ea5beb4ab430138a6077 Azure:
hequn8128 commented on pull request #12160:
URL: https://github.com/apache/flink/pull/12160#issuecomment-629031753
Still not sure about the reasons, I have reverted the related commits for
safety consideration. The test begins normally now. I will check more later.
Sorry about this.
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425570222
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffle.java
##
@@ -0,0
Tzu-Li (Gordon) Tai created FLINK-17712:
---
Summary: Upgrade Flink version to 1.10.1 in Stateful Functions
Key: FLINK-17712
URL: https://issues.apache.org/jira/browse/FLINK-17712
Project: Flink
tzulitai commented on a change in pull request #110:
URL: https://github.com/apache/flink-statefun/pull/110#discussion_r425563507
##
File path:
statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/httpfn/HttpFunctionProvider.java
##
@@ -41,12
flinkbot edited a comment on pull request #12150:
URL: https://github.com/apache/flink/pull/12150#issuecomment-628604536
## CI report:
* e0e57e5b94fe42e04146af4796431cdc40efc2bb Azure:
flinkbot edited a comment on pull request #12112:
URL: https://github.com/apache/flink/pull/12112#issuecomment-627844596
## CI report:
* caebbb2978136a5c36059cef6dcfde1b97f26456 Azure:
flinkbot edited a comment on pull request #12157:
URL: https://github.com/apache/flink/pull/12157#issuecomment-628732224
## CI report:
* c72006072a887727d7ac814ef85576ae3c9a6bd7 UNKNOWN
* 409246b65de6c5e76e6462ed4a55d73c7dc76c22 Travis:
flinkbot edited a comment on pull request #12132:
URL: https://github.com/apache/flink/pull/12132#issuecomment-628151415
## CI report:
* 09465d2623a839311aa67ddfac4059f525f2b62c Azure:
flinkbot edited a comment on pull request #12025:
URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121
## CI report:
* 04db04d8d1b41ca05618c5b09b83b3031bf7ee11 Azure:
[
https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Canbin Zheng updated FLINK-15648:
-
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support to configure
[
https://issues.apache.org/jira/browse/FLINK-15648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Canbin Zheng updated FLINK-15648:
-
Parent: (was: FLINK-14460)
Issue Type: New Feature (was: Sub-task)
> Support to
flinkbot edited a comment on pull request #11010:
URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412
## CI report:
* 1130280dfe557a0268fed248089fb32d15f832d9 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160664763) Azure:
[
https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107940#comment-17107940
]
Yu Li commented on FLINK-17706:
---
I'm ok with licensing my contributions to the Apache License 2.0
Thanks
wangyang0918 commented on a change in pull request #11010:
URL: https://github.com/apache/flink/pull/11010#discussion_r425563975
##
File path:
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesResourceManager.java
##
@@ -91,6 +93,8 @@
/** The number
KarmaGYZ commented on a change in pull request #11854:
URL: https://github.com/apache/flink/pull/11854#discussion_r425552834
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/ResourceInformationReflectorTest.java
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107933#comment-17107933
]
Tzu-Li (Gordon) Tai edited comment on FLINK-17611 at 5/15/20, 4:43 AM:
[
https://issues.apache.org/jira/browse/FLINK-17611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107933#comment-17107933
]
Tzu-Li (Gordon) Tai commented on FLINK-17611:
-
[~igal] concerning the YAML spec format:
KarmaGYZ commented on a change in pull request #11854:
URL: https://github.com/apache/flink/pull/11854#discussion_r425562704
##
File path:
flink-yarn/src/main/java/org/apache/flink/yarn/ResourceInformationReflector.java
##
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15662:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: Improvement)
> Make K8s client timeouts
[
https://issues.apache.org/jira/browse/FLINK-15662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15662:
--
Parent: (was: FLINK-14460)
Issue Type: Improvement (was: Sub-task)
> Make K8s client
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425560889
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java
##
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425560889
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java
##
[
https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15871:
--
Fix Version/s: (was: 1.11.0)
1.12.0
> Support to start sidecar container
>
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425560889
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleConsumer.java
##
[
https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15871:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support to start sidecar
[
https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15642:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support to set JobManager
[
https://issues.apache.org/jira/browse/FLINK-15642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15642:
--
Parent: (was: FLINK-14460)
Issue Type: New Feature (was: Sub-task)
> Support to set
[
https://issues.apache.org/jira/browse/FLINK-15641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15641:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support to start init
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425559040
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/KafkaShuffleFetcher.java
##
@@
tzulitai commented on pull request #108:
URL: https://github.com/apache/flink-statefun/pull/108#issuecomment-629018405
@igalshilman I've addressed all comments except from the one about using
Docker named volumes. Please let me know what you think, and if there are no
further objections,
Zakelly commented on pull request #12112:
URL: https://github.com/apache/flink/pull/12112#issuecomment-629017825
> @Zakelly thanks for your contribution, I left some comments.
Thanks for the detailed review from @klion26 . I have made a new commit.
[
https://issues.apache.org/jira/browse/FLINK-17709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107924#comment-17107924
]
Canbin Zheng commented on FLINK-17709:
--
Sounds great!
> Active Kubernetes integration phase 3 -
Myasuka commented on pull request #8693:
URL: https://github.com/apache/flink/pull/8693#issuecomment-629017420
For the 2nd question @romanovacca , after discussed with @zhijiangW offline,
we believe this PR with cancellation via RPC would not take part in the data
transmission in channel,
[
https://issues.apache.org/jira/browse/FLINK-17457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Li updated FLINK-17457:
---
Parent: (was: FLINK-17198)
Issue Type: Wish (was: Sub-task)
> Manage Hive metadata via Flink
[
https://issues.apache.org/jira/browse/FLINK-14460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-14460:
--
Description:
This is phase 2 of active kubernetes integration. It is a umbrella jira to
track all
flinkbot edited a comment on pull request #12161:
URL: https://github.com/apache/flink/pull/12161#issuecomment-629011624
## CI report:
* fb208fbfdf55bdde668c609a3305d938b8105f95 Azure:
[
https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-14986:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support to get detailed
[
https://issues.apache.org/jira/browse/FLINK-14986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-14986:
--
Parent: (was: FLINK-14460)
Issue Type: New Feature (was: Sub-task)
> Support to get
flinkbot edited a comment on pull request #12119:
URL: https://github.com/apache/flink/pull/12119#issuecomment-628150518
## CI report:
* f2ab38fb3fd70e6fa9f9de2350dfb9b6bb4a477c Azure:
flinkbot edited a comment on pull request #12137:
URL: https://github.com/apache/flink/pull/12137#issuecomment-628291485
## CI report:
* 282fa84594e24e0028e0e87d882c6cd656fcd18b Azure:
[
https://issues.apache.org/jira/browse/FLINK-16760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-16760:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support the yaml file
flinkbot edited a comment on pull request #12025:
URL: https://github.com/apache/flink/pull/12025#issuecomment-625292121
## CI report:
* 04db04d8d1b41ca05618c5b09b83b3031bf7ee11 Azure:
[
https://issues.apache.org/jira/browse/FLINK-15643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15643:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support to start multiple
flinkbot edited a comment on pull request #11385:
URL: https://github.com/apache/flink/pull/11385#issuecomment-597956562
## CI report:
* 9e1bbeafa1a4d0f673ebba7f87ef9032253a29f0 UNKNOWN
* 55bbaced3ca77aecde372a75505363cceb280fb6 Azure:
[
https://issues.apache.org/jira/browse/FLINK-16760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-16760:
--
Parent: (was: FLINK-14460)
Issue Type: New Feature (was: Sub-task)
> Support the yaml
[
https://issues.apache.org/jira/browse/FLINK-15643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15643:
--
Parent: (was: FLINK-14460)
Issue Type: New Feature (was: Sub-task)
> Support to start
flinkbot edited a comment on pull request #11010:
URL: https://github.com/apache/flink/pull/11010#issuecomment-581769412
## CI report:
* 1130280dfe557a0268fed248089fb32d15f832d9 Travis:
[SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160664763) Azure:
[
https://issues.apache.org/jira/browse/FLINK-15871?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-15871:
--
Parent: (was: FLINK-14460)
Issue Type: New Feature (was: Sub-task)
> Support to start
[
https://issues.apache.org/jira/browse/FLINK-17225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yang Wang updated FLINK-17225:
--
Parent: FLINK-17709
Issue Type: Sub-task (was: New Feature)
> Support native k8s for scala
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r42309
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java
##
curcur commented on a change in pull request #11725:
URL: https://github.com/apache/flink/pull/11725#discussion_r425554722
##
File path:
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/shuffle/FlinkKafkaShuffleProducer.java
##
[
https://issues.apache.org/jira/browse/FLINK-17709?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107912#comment-17107912
]
Yang Wang commented on FLINK-17709:
---
Thanks a lot for creating this umbrella tickets and keep working
KarmaGYZ commented on a change in pull request #11854:
URL: https://github.com/apache/flink/pull/11854#discussion_r425553720
##
File path:
flink-yarn/src/test/java/org/apache/flink/yarn/ResourceInformationReflectorTest.java
##
@@ -0,0 +1,171 @@
+/*
+ * Licensed to the Apache
Myasuka commented on a change in pull request #12153:
URL: https://github.com/apache/flink/pull/12153#discussion_r425552234
##
File path:
flink-metrics/flink-metrics-influxdb/src/main/java/org/apache/flink/metrics/influxdb/InfluxdbReporterFactory.java
##
@@ -0,0 +1,14 @@
1 - 100 of 964 matches
Mail list logo
