Github user haohui commented on the issue:
https://github.com/apache/flink/pull/4078
@fhueske @twalthr please take another look. Thanks!
---
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 f
[
https://issues.apache.org/jira/browse/FLINK-6693?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081755#comment-16081755
]
ASF GitHub Bot commented on FLINK-6693:
---
Github user haohui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081616#comment-16081616
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081702#comment-16081702
]
mingleizhang commented on FLINK-6378:
-
Why are we going to remove akka dependency ?
>
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081665#comment-16081665
]
Steven Zhen Wu commented on FLINK-7143:
---
I see. change is for support of multiple to
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081420#comment-16081420
]
Steven Zhen Wu edited comment on FLINK-7143 at 7/11/17 4:51 AM:
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081615#comment-16081615
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user wuchong commented on a diff in
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4279#discussion_r126589762
--- Diff: docs/dev/table/tableApi.md ---
@@ -373,7 +373,7 @@ Table result = orders
Distinct
-Batch
+
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/4279#discussion_r126589666
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/AggregationsTest.scala
---
@@ -39,4 +40,42 @@ class Aggrega
Jark Wu created FLINK-7144:
--
Summary: Optimize multiple LogicalAggregate into one
Key: FLINK-7144
URL: https://issues.apache.org/jira/browse/FLINK-7144
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-6429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081588#comment-16081588
]
Dian Fu commented on FLINK-6429:
Hi [~twalthr], could I know what's the progress of this t
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081474#comment-16081474
]
Tzu-Li (Gordon) Tai commented on FLINK-7143:
[~henryz] yes. One small correcti
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081474#comment-16081474
]
Tzu-Li (Gordon) Tai edited comment on FLINK-7143 at 7/11/17 1:28 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081420#comment-16081420
]
Steven Zhen Wu commented on FLINK-7143:
---
regarding test coverage, we need a test tha
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4150#discussion_r126511039
--- Diff: flink-connectors/flink-connector-kinesis/pom.xml ---
@@ -36,6 +36,8 @@ under the License.
1.10.71
1.6.2
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081386#comment-16081386
]
Tzu-Li (Gordon) Tai commented on FLINK-7143:
IIRC, sorting the fetched partiti
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081386#comment-16081386
]
Tzu-Li (Gordon) Tai edited comment on FLINK-7143 at 7/11/17 12:03 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081386#comment-16081386
]
Tzu-Li (Gordon) Tai edited comment on FLINK-7143 at 7/11/17 12:03 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai reassigned FLINK-7143:
--
Assignee: Tzu-Li (Gordon) Tai
> Partition assignment for Kafka consumer is not
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-7143:
---
Fix Version/s: 1.3.2
> Partition assignment for Kafka consumer is not stable
> ---
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4099
@zentol not sure if this was overlooked. I have rebased to master, is there
anyone you think we should check with before including this package?
---
If your project is set up for it, you can reply
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-6698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081336#comment-16081336
]
Greg Hogan commented on FLINK-6698:
---
[~Zentol] what is the best strategy for continuing
Steven Zhen Wu created FLINK-7143:
-
Summary: Partition assignment for Kafka consumer is not stable
Key: FLINK-7143
URL: https://issues.apache.org/jira/browse/FLINK-7143
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-6882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081320#comment-16081320
]
ASF GitHub Bot commented on FLINK-6882:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Steven Zhen Wu updated FLINK-7143:
--
Description:
while deploying Flink 1.3 release to hundreds of routing jobs, we found some
issue
[
https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081302#comment-16081302
]
ASF GitHub Bot commented on FLINK-6731:
---
GitHub user greghogan opened a pull request
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/4295
[FLINK-6731] [tests] Activate strict checkstyle for flink-tests
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/greghogan/flink
6731_activate
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4279#discussion_r126534907
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/sql/AggregationsTest.scala
---
@@ -39,4 +40,42 @@ class Aggrega
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4157#discussion_r126541801
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunctionWithUpdateInterval.scala
---
@@ -0,0 +1
[
https://issues.apache.org/jira/browse/FLINK-6649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081184#comment-16081184
]
ASF GitHub Bot commented on FLINK-6649:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081141#comment-16081141
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6388?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081148#comment-16081148
]
ASF GitHub Bot commented on FLINK-6388:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4279#discussion_r126535807
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/stream/table/GroupAggregationsITCase.scala
---
@@ -38,6 +38,43 @@ clas
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3783#discussion_r126536553
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/CodeGenerator.scala
---
@@ -296,6 +299,39 @@ class CodeGenerator(
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081139#comment-16081139
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081142#comment-16081142
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081140#comment-16081140
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user fhueske commented on a diff in
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4279#discussion_r126534385
--- Diff: docs/dev/table/tableApi.md ---
@@ -373,7 +373,7 @@ Table result = orders
Distinct
-Batch
+
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4279#discussion_r126532548
--- Diff: docs/dev/table/sql.md ---
@@ -284,7 +284,7 @@ FROM Orders
Distinct
-Batch
+Batch Streamin
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4293
Seems like this ain't working for a Pull Request. I also checked your local
builds (https://travis-ci.org/NicoK/flink/builds/251943625 &
https://travis-ci.org/NicoK/flink/builds/252022358) but it' har
[
https://issues.apache.org/jira/browse/FLINK-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16081095#comment-16081095
]
ASF GitHub Bot commented on FLINK-7141:
---
Github user zentol commented on the issue:
Github user heytitle commented on the issue:
https://github.com/apache/flink/pull/3511
Hi @greghogan,
Thank very much for the feedback.
> Are you able to continue working on this feature?
Yes, I would like to complete the feature and will take a look into th
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-2170:
Assignee: Usman Younas (was: Owen O'Malley)
> Add OrcTableSource
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080898#comment-16080898
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080879#comment-16080879
]
ASF GitHub Bot commented on FLINK-7127:
---
GitHub user mylog00 opened a pull request:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4150
@tzulitai @tedyu
Hi guys, I'm also wondering how much percentage of Flink users are using
Flink with Kinesis? Kinesis has so many limitations that we are considering to
move from Kinesis
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080911#comment-16080911
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080907#comment-16080907
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4150#discussion_r126509865
--- Diff: docs/setup/aws.md ---
@@ -224,8 +224,6 @@ Depending on which file system you use, please add the
following dependencies. Y
- `S3AFileSystem`
GitHub user mylog00 opened a pull request:
https://github.com/apache/flink/pull/4294
[FLINK-7127] [runtime] Remove unnecessary null check or add null check;
Hi. To avoid NPE I decided add null check instead remove it one.
You can merge this pull request into a Git repository by run
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4136#discussion_r126503269
--- Diff: docs/ops/state_backends.md ---
@@ -123,8 +123,7 @@ RocksDBStateBackend is currently the only backend that
offers incremental checkp
##
[
https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080832#comment-16080832
]
ASF GitHub Bot commented on FLINK-6940:
---
Github user bowenli86 commented on a diff i
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4183
Yes, @fhueske you are right, we must define watermark for each table. And I
was trying to consider the semantics of Flink configs, including (FLINK-6649,
FLINK-6962, FLINK-6969 etc), I was wri
[
https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080719#comment-16080719
]
ASF GitHub Bot commented on FLINK-6969:
---
Github user sunjincheng121 commented on the
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3511
@heytitle apologies for the long delay. I've been working to improve the
Gelly examples to process with each of the standard data types (from byte to
string). I think we can validate both the corre
[
https://issues.apache.org/jira/browse/FLINK-2170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080656#comment-16080656
]
Usman Younas commented on FLINK-2170:
-
Hi [~fhueske] I'd like to work on OrcTableSourc
Fabian Hueske created FLINK-7142:
Summary: Scala DataSet API ignores ResultTypeQueryable interface
Key: FLINK-7142
URL: https://issues.apache.org/jira/browse/FLINK-7142
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-7050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-7050:
Assignee: Usman Younas
> RFC Compliant CSV Parser for Table Source
> --
[
https://issues.apache.org/jira/browse/FLINK-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080548#comment-16080548
]
ASF GitHub Bot commented on FLINK-6901:
---
Github user uce commented on a diff in the
Github user uce commented on a diff in the pull request:
https://github.com/apache/flink/pull/4112#discussion_r126464199
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyBufferPool.java
---
@@ -61,7 +60,9 @@ public NettyBufferPool(int numberOfAr
[
https://issues.apache.org/jira/browse/FLINK-6358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6358:
--
Fix Version/s: 1.4.0
> Write job details for Gelly examples
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-5253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080495#comment-16080495
]
Mariusz Wojakowski commented on FLINK-5253:
---
Thanks for the comments! I'll take
[
https://issues.apache.org/jira/browse/FLINK-6357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080484#comment-16080484
]
ASF GitHub Bot commented on FLINK-6357:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4169#discussion_r126452583
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java
---
@@ -278,6 +518,26 @@ public void testUnrequestedRequired() {
[
https://issues.apache.org/jira/browse/FLINK-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080483#comment-16080483
]
ASF GitHub Bot commented on FLINK-6901:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4112#discussion_r126451783
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyBufferPool.java
---
@@ -61,7 +60,9 @@ public NettyBufferPool(int numberOf
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4169#discussion_r126450338
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/utils/ParameterToolTest.java
---
@@ -174,9 +210,38 @@ public void testUnrequestedByte() {
[
https://issues.apache.org/jira/browse/FLINK-6357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080478#comment-16080478
]
ASF GitHub Bot commented on FLINK-6357:
---
Github user greghogan commented on a diff i
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4110#discussion_r126443494
--- Diff:
flink-metrics/flink-metrics-statsd/src/main/java/org/apache/flink/metrics/statsd/StatsDReporter.java
---
@@ -193,7 +198,10 @@ private void send(fina
[
https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080447#comment-16080447
]
ASF GitHub Bot commented on FLINK-6900:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080470#comment-16080470
]
ASF GitHub Bot commented on FLINK-6900:
---
Github user greghogan commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-7063.
-
Resolution: Fixed
Fixed in 74adb84742.
> test instability in OperatorStateBackendTest.testSnapsho
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4110#discussion_r126446702
--- Diff: docs/monitoring/metrics.md ---
@@ -376,6 +376,7 @@ Parameters:
- `dmax` - hard limit for how long an old metric should be retained
- `tt
[
https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080427#comment-16080427
]
ASF GitHub Bot commented on FLINK-7063:
---
Github user StefanRRichter closed the pull
[
https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080449#comment-16080449
]
ASF GitHub Bot commented on FLINK-6900:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6900?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080448#comment-16080448
]
ASF GitHub Bot commented on FLINK-6900:
---
Github user NicoK commented on a diff in th
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4110#discussion_r126442516
--- Diff:
flink-metrics/flink-metrics-dropwizard/src/main/java/org/apache/flink/dropwizard/ScheduledDropwizardReporter.java
---
@@ -184,7 +188,10 @@ public vo
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4110#discussion_r126443486
--- Diff:
flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java
---
@@ -60,6 +60,20 @@
public class St
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4183
I think support for watermark configuration in a DDL statement is a nice
feature but not a replacement for this parameter.
I am thinking of a use case where streaming tables are registered in
[
https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080413#comment-16080413
]
ASF GitHub Bot commented on FLINK-7063:
---
Github user NicoK commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-6969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080429#comment-16080429
]
ASF GitHub Bot commented on FLINK-6969:
---
Github user fhueske commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/4246
Thanks for the review @NicoK !
Merged in 74adb84742.
---
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 do
Github user StefanRRichter closed the pull request at:
https://github.com/apache/flink/pull/4246
---
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
[
https://issues.apache.org/jira/browse/FLINK-7063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080426#comment-16080426
]
ASF GitHub Bot commented on FLINK-7063:
---
Github user StefanRRichter commented on the
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/4246#discussion_r126437776
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/async/AsyncStoppableTaskWithCallback.java
---
@@ -21,6 +21,7 @@
import org.apache.flink
[
https://issues.apache.org/jira/browse/FLINK-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080394#comment-16080394
]
ASF GitHub Bot commented on FLINK-7141:
---
Github user NicoK commented on the issue:
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4293
that's actually hard to know in advance - I had only 3 builds that went
under the limit by chance so I was able to use the cache henceforth in those
three which constantly were below the 49min. This PR
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4256
---
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 enab
Github user alpinegizmo commented on a diff in the pull request:
https://github.com/apache/flink/pull/4136#discussion_r126431179
--- Diff: docs/ops/state_backends.md ---
@@ -123,8 +123,7 @@ RocksDBStateBackend is currently the only backend that
offers incremental checkp
[
https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080361#comment-16080361
]
ASF GitHub Bot commented on FLINK-6747:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080355#comment-16080355
]
ASF GitHub Bot commented on FLINK-6747:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4256
Thanks for the review @sunjincheng121!
I addressed your points and will merge the PR.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub a
[
https://issues.apache.org/jira/browse/FLINK-6940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16080363#comment-16080363
]
ASF GitHub Bot commented on FLINK-6940:
---
Github user alpinegizmo commented on a diff
1 - 100 of 180 matches
Mail list logo
