Github user EronWright commented on the issue:
https://github.com/apache/flink/pull/4560
@tillrohrmann fixed the test issue and other noted issues. Once #4555 is
in, this is good to go.
The test issue was a race in RM acquiring leadership vs RPC call. Added
some code to
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133888#comment-16133888
]
Dian Fu edited comment on FLINK-7479 at 8/19/17 2:27 AM:
-
Hi [~kkl0u],
Thanks a
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133888#comment-16133888
]
Dian Fu commented on FLINK-7479:
Hi [~kkl0u],
{quote}
Before opening a PR for a feature, we first have to
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133628#comment-16133628
]
Kostas Kloudas commented on FLINK-7479:
---
Hi [~dian.fu],
Before opening a PR for a feature, we
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133557#comment-16133557
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user rangadi commented on a diff in the pull
Github user rangadi commented on a diff in the pull request:
https://github.com/apache/flink/pull/4239#discussion_r134044031
--- Diff:
flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java
---
@@ -0,0
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4560#discussion_r134004745
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskManagerRegistration.java
---
@@ -68,7 +68,9 @@ public
Github user EronWright commented on a diff in the pull request:
https://github.com/apache/flink/pull/4560#discussion_r134003593
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -960,12 +965,26 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133184#comment-16133184
]
ASF GitHub Bot commented on FLINK-7442:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4564
Thanks, this looks better to me!
I would suggest to not pass the configuration into the library cache
manager.
I think passing configuration objects into specialized / dedicated
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133174#comment-16133174
]
ASF GitHub Bot commented on FLINK-7477:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4566
@rmetzger I addressed your comments.
---
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-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133142#comment-16133142
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4525
I think `null` values are not really permitted at the moment, but I think
the InputFormats do not explicitly forbid them. That's why the logic is not
"run until returns null", but "run until
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133120#comment-16133120
]
ASF GitHub Bot commented on FLINK-7477:
---
Github user rmetzger commented on a diff in the pull
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/4566#discussion_r133985865
--- Diff: flink-dist/src/main/flink-bin/bin/config.sh ---
@@ -351,8 +351,20 @@ if [ -z "$HADOOP_CONF_DIR" ]; then
fi
fi
+# try and
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/4566#discussion_r133985612
--- Diff: flink-dist/src/main/flink-bin/bin/config.sh ---
@@ -351,8 +351,20 @@ if [ -z "$HADOOP_CONF_DIR" ]; then
fi
fi
+# try and
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133119#comment-16133119
]
ASF GitHub Bot commented on FLINK-7477:
---
Github user rmetzger commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133118#comment-16133118
]
Robert Metzger commented on FLINK-7480:
---
+1
> Set HADOOP_CONF_DIR to sane default if not set
>
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4560#discussion_r133980216
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java
---
@@ -960,12 +965,26 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4560#discussion_r133980386
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/slotmanager/TaskManagerRegistration.java
---
@@ -68,7 +68,9 @@ public
[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133081#comment-16133081
]
ASF GitHub Bot commented on FLINK-7402:
---
Github user tedyu commented on a diff in the pull request:
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4562#discussion_r133980441
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -220,6 +220,10 @@ void releaseBuffer() {
[
https://issues.apache.org/jira/browse/FLINK-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133058#comment-16133058
]
ASF GitHub Bot commented on FLINK-6630:
---
Github user tillrohrmann commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133057#comment-16133057
]
ASF GitHub Bot commented on FLINK-6630:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4555#discussion_r133974899
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133056#comment-16133056
]
ASF GitHub Bot commented on FLINK-6630:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4555#discussion_r133974223
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosEntrypointUtils.java
---
@@ -0,0 +1,175 @@
+/*
+ * Licensed to the
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4555#discussion_r133975661
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosTaskExecutorRunner.java
---
@@ -0,0 +1,140 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133055#comment-16133055
]
ASF GitHub Bot commented on FLINK-6630:
---
Github user tillrohrmann commented on a diff in the pull
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/4555#discussion_r133975100
--- Diff:
flink-mesos/src/main/java/org/apache/flink/mesos/entrypoint/MesosJobClusterEntrypoint.java
---
@@ -0,0 +1,207 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133053#comment-16133053
]
Aljoscha Krettek commented on FLINK-7300:
-
The reason this time is an {{AskTimeoutException}}. The
[
https://issues.apache.org/jira/browse/FLINK-7446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133050#comment-16133050
]
Xingcan Cui commented on FLINK-7446:
Thanks for the response, [~fhueske]. From my perspective, I
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133044#comment-16133044
]
ASF GitHub Bot commented on FLINK-7477:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4566
[FLINK-7477] [FLINK-7480] Various improvements to Flink scripts
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
[
https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7477:
Fix Version/s: 1.4.0
> Use "hadoop classpath" to augment classpath when available
>
Aljoscha Krettek created FLINK-7480:
---
Summary: Set HADOOP_CONF_DIR to sane default if not set
Key: FLINK-7480
URL: https://issues.apache.org/jira/browse/FLINK-7480
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133031#comment-16133031
]
Jark Wu commented on FLINK-7471:
Hi [~fhueske], I think [~sunjincheng121] mean that retraction for over
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/4530
Thanks for the comment, @aljoscha. IMO, making the `timeServiceManager`
protected indeed will minimise the impact on `AbstractStreamOperator`, while
that may introduce duplicated codes in the
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133027#comment-16133027
]
ASF GitHub Bot commented on FLINK-7245:
---
Github user xccui commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu updated FLINK-7479:
---
Summary: Support to retrieve the past event by physical offset (was:
Support to retrieve the past event by
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16133007#comment-16133007
]
Dian Fu commented on FLINK-7479:
This is to support the {{PREV}} clause in {{MATCH_RECOGNIZE}}. As
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/4553
Afaik the problem is that the doc builders are independent of Flink
version. So we use the same toolchain for building 0.8 docs and 1.4 docs.
The `flink.conf` file in
[
https://issues.apache.org/jira/browse/FLINK-7429?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132182#comment-16132182
]
ASF GitHub Bot commented on FLINK-7429:
---
GitHub user tzulitai opened a pull request:
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/4565
[FLINK-7429] [kinesis] Add migration test coverage for Flink 1.2 and 1.3
## What is the purpose of the change
The migration tests for the Kinesis consumer did not cover Flink 1.2 and
1.3.
[
https://issues.apache.org/jira/browse/FLINK-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132174#comment-16132174
]
ASF GitHub Bot commented on FLINK-7245:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4530
I think the approach is OK, though I personally would have preferred to
make the instance variable protected and override `processWatermark()` to
minimise impact on `AbstractStreamOperator`, which
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132172#comment-16132172
]
ASF GitHub Bot commented on FLINK-7442:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4554
Yes, I created an alternative PR for that:
https://github.com/apache/flink/pull/4564
My only worry is that all the tests in that PR would also pass with the
other child-first class loader
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132168#comment-16132168
]
ASF GitHub Bot commented on FLINK-7442:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/4564
[FLINK-7442] Add option for using child-first classloader for loading user
code
This is an alternative to #4554 that does not make the client class loader
configurable.
## What is the
[
https://issues.apache.org/jira/browse/FLINK-7479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132141#comment-16132141
]
ASF GitHub Bot commented on FLINK-7479:
---
GitHub user dianfu opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/4563
[FLINK-7479] [cep] Support to retrieve the past event by an offset
## What is the purpose of the change
*Currently, it's already able to retrieve events matched to the specifed
pattern in
Dian Fu created FLINK-7479:
--
Summary: Support to retrieve the past event by an offset
Key: FLINK-7479
URL: https://issues.apache.org/jira/browse/FLINK-7479
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-7473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132125#comment-16132125
]
Nico Kruber commented on FLINK-7473:
Another fix: properly fix your event time use (which is the
[
https://issues.apache.org/jira/browse/FLINK-7129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132111#comment-16132111
]
Dawid Wysakowicz commented on FLINK-7129:
-
Hi [~dian.fu]
Yes the idea was to enable multiple
[
https://issues.apache.org/jira/browse/FLINK-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132090#comment-16132090
]
sunjincheng commented on FLINK-7471:
We know it's poor compute if all aggregates for each record
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132062#comment-16132062
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/4525
@StephanEwen why are `null` values permitted if not in the contract of the
input formats?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as
lincoln.lee created FLINK-7478:
--
Summary: Update documentation for sql insert and api change in
TableAPI & SQL
Key: FLINK-7478
URL: https://issues.apache.org/jira/browse/FLINK-7478
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132056#comment-16132056
]
ASF GitHub Bot commented on FLINK-7358:
---
Github user sunjincheng121 commented on the issue:
Github user sunjincheng121 commented on the issue:
https://github.com/apache/flink/pull/4534
Hi, @fhueske Thank you for reminding me :-). I updated the description. and
feel free to tell me if there is any inappropriate description.
Thanks, jincheng
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132042#comment-16132042
]
ASF GitHub Bot commented on FLINK-7206:
---
Github user kaibozhou commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132041#comment-16132041
]
ASF GitHub Bot commented on FLINK-7068:
---
Github user NicoK commented on the issue:
Github user kaibozhou commented on the issue:
https://github.com/apache/flink/pull/4355
1. Use HeapMapView/HeapListView as default implementation
2. add initialize and cleanUp interface to GeneratedAggregations
---
If your project is set up for it, you can reply to this email and
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/4358
Rebased onto `master`, but had to drag in #4402 early to fix the end-to-end
tests failing due to spurious warnings. The test failure you observed was
actually a test instability introduced with #4238
Github user kaibozhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/4355#discussion_r133925176
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -179,13 +214,19 @@ class
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132016#comment-16132016
]
ASF GitHub Bot commented on FLINK-7206:
---
Github user kaibozhou commented on a diff in the pull
Github user kaibozhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/4355#discussion_r133925097
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/codegen/AggregationCodeGenerator.scala
---
@@ -405,6 +481,17 @@ class
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132017#comment-16132017
]
ASF GitHub Bot commented on FLINK-7206:
---
Github user kaibozhou commented on a diff in the pull
Github user kaibozhou commented on a diff in the pull request:
https://github.com/apache/flink/pull/4355#discussion_r133924725
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedAggFunctions.java
---
@@ -135,4 +138,172 @@
[
https://issues.apache.org/jira/browse/FLINK-7206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16132010#comment-16132010
]
ASF GitHub Bot commented on FLINK-7206:
---
Github user kaibozhou commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131997#comment-16131997
]
ASF GitHub Bot commented on FLINK-7442:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4554
I think what you mentioned is one more reason to not use this in too many
places for now, but only inside the TaskManager / Tasks. Let's introduce that
as a tool that users can use to resolve
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131995#comment-16131995
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-6442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131996#comment-16131996
]
ASF GitHub Bot commented on FLINK-6442:
---
Github user lincoln-lil commented on a diff in the pull
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r133920847
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/queryConfig.scala
---
@@ -19,9 +19,21 @@
package
Github user lincoln-lil commented on a diff in the pull request:
https://github.com/apache/flink/pull/3829#discussion_r133921697
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -502,26 +513,140 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-7423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131993#comment-16131993
]
ASF GitHub Bot commented on FLINK-7423:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4525
The logic is currently not correct with the contract of the input formats.
A return value of null is not an "end of split" indicator.
Also, the description mentions that this adds a
Aljoscha Krettek created FLINK-7477:
---
Summary: Use "hadoop classpath" to augment classpath when available
Key: FLINK-7477
URL: https://issues.apache.org/jira/browse/FLINK-7477
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7475:
Component/s: DataStream API
> ListState support update
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131967#comment-16131967
]
ASF GitHub Bot commented on FLINK-7347:
---
Github user aljoscha commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4454
@twalthr, kindly reminder :)
---
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
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4468
Thanks a lot for contributing this fix, @ymost! ð
I merged into master, could you please close this PR?
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek closed FLINK-7347.
---
Resolution: Fixed
Implemented in 76f1022884fe7b291fe81028a29896fb5b5ca5c9 on master.
>
[
https://issues.apache.org/jira/browse/FLINK-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek reassigned FLINK-7347:
---
Assignee: Yonatan Most
> "removeAll" is extremely inefficient in
>
[
https://issues.apache.org/jira/browse/FLINK-7347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7347:
Fix Version/s: 1.4.0
> "removeAll" is extremely inefficient in
>
[
https://issues.apache.org/jira/browse/FLINK-7465?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131948#comment-16131948
]
Jark Wu commented on FLINK-7465:
I think the problem is how to design the state. Even if it is a bitarray
[
https://issues.apache.org/jira/browse/FLINK-7402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131944#comment-16131944
]
ASF GitHub Bot commented on FLINK-7402:
---
GitHub user zjureel opened a pull request:
GitHub user zjureel opened a pull request:
https://github.com/apache/flink/pull/4562
[FLINK-7402] Fix ineffective null check in NettyMessage#write()
## What is the purpose of the change
Fix ineffective null check in NettyMessage#write()
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131926#comment-16131926
]
ASF GitHub Bot commented on FLINK-7442:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4554
Probably, yes. I also don't know what other stuff this could break, though.
For example, I don't know if queryable state, which starts netty (and Akka)
stuff will still work with this.
[
https://issues.apache.org/jira/browse/FLINK-6988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131913#comment-16131913
]
ASF GitHub Bot commented on FLINK-6988:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4239
Implemented fixed size pool of producers, please check last commit.
If we run out of producers in the pool, exception is being thrown aborting
ongoing snapshot.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131907#comment-16131907
]
ASF GitHub Bot commented on FLINK-7476:
---
GitHub user pnowojski opened a pull request:
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/4561
[FLINK-7476][streaming] Continue using previous transaction on failures
First commit comes from #4557.
Previously when using TwoPhaseCommitSinkFunction, if there was some
intermittent
[
https://issues.apache.org/jira/browse/FLINK-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7476:
Affects Version/s: 1.4.0
> Try to recover from failure in
[
https://issues.apache.org/jira/browse/FLINK-7476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-7476:
Fix Version/s: 1.4.0
> Try to recover from failure in
[
https://issues.apache.org/jira/browse/FLINK-7442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16131889#comment-16131889
]
ASF GitHub Bot commented on FLINK-7442:
---
Github user StephanEwen commented on the issue:
1 - 100 of 124 matches
Mail list logo
