Scott Kidder created FLINK-5946:
---
Summary: Kinesis Producer uses KPL that orphans threads that
consume 100% CPU
Key: FLINK-5946
URL: https://issues.apache.org/jira/browse/FLINK-5946
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891296#comment-15891296
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user chenqin commented on the issue:
Github user chenqin commented on the issue:
https://github.com/apache/flink/pull/2982
@aljoscha
Nice! Let's do "Chen Qin qinnc...@gmail.com"
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103806696
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -737,101 +632,121 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891306#comment-15891306
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103801735
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891307#comment-15891307
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103806213
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -737,101 +632,121 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891305#comment-15891305
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103807487
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -54,31 +58,31 @@ object
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103818316
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -737,101 +632,121 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891311#comment-15891311
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891310#comment-15891310
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103801835
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891309#comment-15891309
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891308#comment-15891308
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user fhueske commented on a diff in the pull
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103818719
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateAggFunction.scala
---
@@ -0,0 +1,101 @@
+/*
[
https://issues.apache.org/jira/browse/FLINK-5486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15822346#comment-15822346
]
Ted Yu edited comment on FLINK-5486 at 3/2/17 12:35 AM:
Lock on State.bucketStates
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103835523
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -54,31 +58,31 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891454#comment-15891454
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a diff in the pull
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3450
Looks good to me too. I will merge it.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891447#comment-15891447
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891449#comment-15891449
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891448#comment-15891448
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891450#comment-15891450
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user hongyuhong commented on a diff in the pull
Xiaojun Jin created FLINK-5947:
--
Summary: NullPointerException in
ContinuousProcessingTimeTrigger.clear()
Key: FLINK-5947
URL: https://issues.apache.org/jira/browse/FLINK-5947
Project: Flink
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835088
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/aggs/DoubleSummaryAggregation.java
---
@@ -0,0 +1,214
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835059
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/logical/rel/util/WindowAggregateUtil.java
---
@@ -0,0 +1,103 @@
+/*
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835080
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/DataStreamProcTimeRowAggregate.java
---
@@ -0,0 +1,160
Github user hongyuhong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103835113
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891441#comment-15891441
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891407#comment-15891407
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user wuchong commented on the issue:
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103834968
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/DataSetSessionWindowAggregateReduceGroupFunction.scala
---
[
https://issues.apache.org/jira/browse/FLINK-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890445#comment-15890445
]
Greg Hogan commented on FLINK-2910:
---
Do we want to consider changing these from integration tests (using
GitHub user huawei-flink opened a pull request:
https://github.com/apache/flink/pull/3443
[FLINK-5653] Add processing time OVER ROWS BETWEEN x PRECEDING aggregation
to SQL
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890481#comment-15890481
]
ASF GitHub Bot commented on FLINK-5653:
---
GitHub user huawei-flink opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891562#comment-15891562
]
sunjincheng commented on FLINK-5740:
+1 very good point， any news for this issue? [~aljoscha]
> Make
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891567#comment-15891567
]
sunjincheng edited comment on FLINK-5947 at 3/2/17 3:40 AM:
[~Xiaojun Jin] In
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891714#comment-15891714
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891715#comment-15891715
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891717#comment-15891717
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891716#comment-15891716
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891558#comment-15891558
]
sunjincheng edited comment on FLINK-5947 at 3/2/17 3:23 AM:
Hi, @Xiaojun Jin
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Description:
Reported in ML:
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891584#comment-15891584
]
Xiaojun Jin commented on FLINK-5947:
Yes. I have maintained a separate version of flink in my company
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891584#comment-15891584
]
Xiaojun Jin edited comment on FLINK-5947 at 3/2/17 4:00 AM:
Yes
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Fix Version/s: 1.2.1
> Flink on YARN checks for Kerberos credentials for non-Kerberos
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Priority: Blocker (was: Critical)
> Flink on YARN checks for Kerberos credentials
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891697#comment-15891697
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user tzulitai commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5134:
Summary: Aggregate ResourceSpec for chained operators when generating job
graph (was: Aggregate
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-5794.
--
Resolution: Fixed
Fix Version/s: 1.3.0
fixed in bf4eed144428179a2390eb67642f8ac755896fc2
> update the
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3450
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891530#comment-15891530
]
ASF GitHub Bot commented on FLINK-5794:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891558#comment-15891558
]
sunjincheng commented on FLINK-5947:
Hi, @Xiaojun Jin thanks for reporter this issue. Can you describe
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891567#comment-15891567
]
sunjincheng commented on FLINK-5947:
[~Xiaojun Jin] In your exception information, the error line
[
https://issues.apache.org/jira/browse/FLINK-5949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5949:
---
Component/s: YARN
> Flink on YARN checks for Kerberos credentials for non-Kerberos
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3420
Thanks for the fix @jinmingjian. LGTM, merging the PRs now.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3422
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3419
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3421
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3420
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-5134:
Description:
This is a part of fine-grained resource configuration in flip-6.
In *JobGraph* generation,
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891754#comment-15891754
]
Tzu-Li (Gordon) Tai commented on FLINK-4422:
Fixes for the Kafka connector modules have been
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891644#comment-15891644
]
Xiaojun Jin commented on FLINK-5947:
[~sunjincheng] thanks for your answer. I have solved this bug.
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891644#comment-15891644
]
Xiaojun Jin edited comment on FLINK-5947 at 3/2/17 5:12 AM:
[~sunjincheng121]
[
https://issues.apache.org/jira/browse/FLINK-5134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891694#comment-15891694
]
ASF GitHub Bot commented on FLINK-5134:
---
GitHub user zhijiangW opened a pull request:
GitHub user zhijiangW opened a pull request:
https://github.com/apache/flink/pull/3455
[FLINK-5134][runtime]Aggregate ResourceSpe for chained operators when
generating JobGraph
It is a part of fine-grained resource configuration in 'flip-6'.
In 'JobGraph' generation, each
[
https://issues.apache.org/jira/browse/FLINK-5768?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891503#comment-15891503
]
ASF GitHub Bot commented on FLINK-5768:
---
Github user shaoxuan-wang commented on a diff in the pull
Github user shaoxuan-wang commented on a diff in the pull request:
https://github.com/apache/flink/pull/3423#discussion_r103839943
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/AggregateUtil.scala
---
@@ -363,199 +342,112 @@ object
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891602#comment-15891602
]
sunjincheng commented on FLINK-5947:
I think the reason for this problem may be for merge state.when
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891695#comment-15891695
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4789 at 3/2/17 6:32 AM:
I
[
https://issues.apache.org/jira/browse/FLINK-4789?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891695#comment-15891695
]
Tzu-Li (Gordon) Tai commented on FLINK-4789:
I think this issue is partially fixed already.
[
https://issues.apache.org/jira/browse/FLINK-4714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891545#comment-15891545
]
Wei-Che Wei commented on FLINK-4714:
Hi [~till.rohrmann]
I have some ideas about this issue and I
Geoffrey Mon created FLINK-5948:
---
Summary: Error in Python zip_with_index documentation
Key: FLINK-5948
URL: https://issues.apache.org/jira/browse/FLINK-5948
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-5947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891654#comment-15891654
]
sunjincheng commented on FLINK-5947:
[~Xiaojun Jin] Congratulations you solved this bug,cheers !!!
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/3420#discussion_r103861044
--- Diff:
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/internals/KillerWatchDog.java
---
@@ -42,12
[
https://issues.apache.org/jira/browse/FLINK-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891706#comment-15891706
]
ASF GitHub Bot commented on FLINK-4422:
---
Github user tzulitai commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891756#comment-15891756
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on a diff in the pull
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103866134
--- Diff:
flink-libraries/flink-table/src/main/java/org/apache/flink/table/plan/nodes/datastream/aggs/DoubleSummaryAggregation.java
---
@@ -0,0 +1,214
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891757#comment-15891757
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user huawei-flink commented on a diff in the pull
Github user huawei-flink commented on a diff in the pull request:
https://github.com/apache/flink/pull/3443#discussion_r103866164
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/api/java/stream/sql/ProcTimeRowStreamAggregationSqlITCase.java
---
@@ -0,0
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/3376
merging.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3449
[backport-1.2] [FLINK-5942] [checkpoint] Harden ZooKeeperStateHandleStore
to handle corrupt data
Backport of #3446 onto the `release-1.2` branch.
If calling
[
https://issues.apache.org/jira/browse/FLINK-5942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890591#comment-15890591
]
ASF GitHub Bot commented on FLINK-5942:
---
GitHub user tillrohrmann opened a pull request:
GitHub user sunjincheng121 opened a pull request:
https://github.com/apache/flink/pull/3450
[FLINK-5794][doc] update the documentation about âUDF/UDTF" support hâ¦
â¦ave parameters constructor.
Thanks for contributing to Apache Flink. Before you open your pull request,
[
https://issues.apache.org/jira/browse/FLINK-5940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890590#comment-15890590
]
ASF GitHub Bot commented on FLINK-5940:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890631#comment-15890631
]
ASF GitHub Bot commented on FLINK-5940:
---
GitHub user tillrohrmann opened a pull request:
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/3451
[backport-1.1] [FLINK-5940] [checkpoint] Harden
ZooKeeperCompletedCheckpointStore.recover method
Backpor of #3446 onto `release-1.1` branch.
The ZooKeeperCompletedCheckpointStore only
[
https://issues.apache.org/jira/browse/FLINK-5219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890649#comment-15890649
]
ASF GitHub Bot commented on FLINK-5219:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890666#comment-15890666
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on a diff in the pull
Github user DmytroShkvyra commented on a diff in the pull request:
https://github.com/apache/flink/pull/2870#discussion_r103734557
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/api/table/codegen/calls/ScalarOperators.scala
---
@@ -1002,12 +1068,17 @@
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890547#comment-15890547
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on a diff in the pull
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/3444
[FLINK-5941] Integrate Archiver pattern into handlers
This PR adds the last piece to the foundation of the HistoryServer. It
builds on top of #3365 and #3376, meaning that only 58649fb is relevant
[
https://issues.apache.org/jira/browse/FLINK-5942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890586#comment-15890586
]
ASF GitHub Bot commented on FLINK-5942:
---
GitHub user tillrohrmann opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890593#comment-15890593
]
ASF GitHub Bot commented on FLINK-5794:
---
GitHub user sunjincheng121 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890529#comment-15890529
]
ASF GitHub Bot commented on FLINK-5870:
---
Github user zentol commented on the issue:
Chesnay Schepler created FLINK-5941:
---
Summary: Let handlers take part in job archiving
Key: FLINK-5941
URL: https://issues.apache.org/jira/browse/FLINK-5941
Project: Flink
Issue Type: New
[
https://issues.apache.org/jira/browse/FLINK-5941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890555#comment-15890555
]
ASF GitHub Bot commented on FLINK-5941:
---
GitHub user zentol opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4565?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15890565#comment-15890565
]
ASF GitHub Bot commented on FLINK-4565:
---
Github user DmytroShkvyra commented on a diff in the pull
Ted Yu created FLINK-5943:
-
Summary: Unprotected access to haServices in
YarnFlinkApplicationMasterRunner#shutdown()
Key: FLINK-5943
URL: https://issues.apache.org/jira/browse/FLINK-5943
Project: Flink
1 - 100 of 290 matches
Mail list logo
