[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber updated FLINK-9305:
---
Summary: Register flink-s3-fs-hadoop for the s3a:// scheme as well (was:
Register flink-s3-fs-* for
[
https://issues.apache.org/jira/browse/FLINK-8933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465782#comment-16465782
]
vinoyang commented on FLINK-8933:
-
[~StephanEwen] so could I split the task into multiple sub tasks for
[
https://issues.apache.org/jira/browse/FLINK-9201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465568#comment-16465568
]
ASF GitHub Bot commented on FLINK-9201:
---
Github user aljoscha commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski closed FLINK-9287.
-
> KafkaProducer011 seems to leak threads when not in exactly-once mode
>
[
https://issues.apache.org/jira/browse/FLINK-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465575#comment-16465575
]
Stefan Richter commented on FLINK-9302:
---
If you take a look at this stack trace, it tells you that
[
https://issues.apache.org/jira/browse/FLINK-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9302.
-
Resolution: Not A Problem
> Checkpoints continues to fail when using filesystem state backend
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465574#comment-16465574
]
ASF GitHub Bot commented on FLINK-9235:
---
Github user zentol commented on a diff in the pull request:
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5953#discussion_r186350834
--- Diff:
flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionFIFOITCase.java
---
@@ -85,21 +91,56 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465683#comment-16465683
]
Alex Chen commented on FLINK-9282:
--
I create a PR for this
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465688#comment-16465688
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user StephanEwen commented on a diff in the pull
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5954#discussion_r186375693
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -212,7 +212,7 @@ public void start(JobMasterId
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5954#discussion_r186375841
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -1050,11 +1050,12 @@ else if
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5954#discussion_r186376326
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/scheduler/SchedulerTestBase.java
---
@@ -296,7 +296,7 @@ public
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5954#discussion_r186376122
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -1070,13 +1071,22 @@ protected void
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/5954#discussion_r186376182
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPoolGateway.java
---
@@ -86,9 +86,10 @@
* Releases a
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465690#comment-16465690
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465687#comment-16465687
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465689#comment-16465689
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465686#comment-16465686
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user StephanEwen commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465691#comment-16465691
]
ASF GitHub Bot commented on FLINK-9194:
---
Github user zentol commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-9250?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465717#comment-16465717
]
Stephan Ewen commented on FLINK-9250:
-
I think we should keep issues open if we intend to follow up -
[
https://issues.apache.org/jira/browse/FLINK-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Chen updated FLINK-9307:
-
Affects Version/s: 1.6.0
> Running flink program doesn't print infos in console any more
>
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8191:
Priority: Major (was: Blocker)
> Add a RoundRobinPartitioner to be shipped with the Kafka
[
https://issues.apache.org/jira/browse/FLINK-6763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6763:
Priority: Major (was: Blocker)
> Inefficient PojoSerializerConfigSnapshot serialization
[
https://issues.apache.org/jira/browse/FLINK-8191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8191:
Fix Version/s: (was: 1.6.0)
> Add a RoundRobinPartitioner to be shipped with the Kafka
[
https://issues.apache.org/jira/browse/FLINK-5479?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-5479:
Priority: Major (was: Blocker)
> Per-partition watermarks in FlinkKafkaConsumer should
[
https://issues.apache.org/jira/browse/FLINK-6764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6764:
Priority: Major (was: Blocker)
> Deduplicate stateless TypeSerializers when serializing
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7913:
Fix Version/s: (was: 1.6.0)
> Add support for Kafka default partitioner
>
[
https://issues.apache.org/jira/browse/FLINK-7913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-7913:
Priority: Major (was: Blocker)
> Add support for Kafka default partitioner
>
[
https://issues.apache.org/jira/browse/FLINK-6944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-6944:
Priority: Major (was: Blocker)
> Introduce DefaultTypeSerializerConfigSnapshot as a base
[
https://issues.apache.org/jira/browse/FLINK-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-8970:
Priority: Major (was: Blocker)
> Add more automated end-to-end tests
>
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5941#discussion_r186415017
--- Diff:
flink-end-to-end-tests/flink-datastream-allround-test/src/main/java/org/apache/flink/streaming/tests/SequenceGeneratorSource.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-9304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465827#comment-16465827
]
ASF GitHub Bot commented on FLINK-9304:
---
GitHub user StefanRRichter opened a pull request:
Seweryn Habdank-Wojewodzki created FLINK-9308:
-
Summary: The method enableCheckpointing with low values like 10
are forming DoS on Kafka Clusters
Key: FLINK-9308
URL:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5954
cc @StephanEwen refactored code base on your suggestion, please review
again, thanks.
---
[
https://issues.apache.org/jira/browse/FLINK-9308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9308:
---
Assignee: vinoyang
> The method enableCheckpointing with low values like 10 are forming DoS on
>
[
https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465920#comment-16465920
]
ASF GitHub Bot commented on FLINK-8971:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5941
As discussed separately, I think that this could be simplified quiet a bit
and that we do not require connected streams. The operator state does not have
to depend on the input events. For
[
https://issues.apache.org/jira/browse/FLINK-9276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465846#comment-16465846
]
ASF GitHub Bot commented on FLINK-9276:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465860#comment-16465860
]
Sergey Nuyanzin commented on FLINK-8255:
Hello [~fhueske]. Thank you very much
I was able to cope
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/5926#discussion_r186412353
--- Diff: flink-end-to-end-tests/run-nightly-tests.sh ---
@@ -58,25 +58,97 @@ fi
if [ $EXIT_CODE == 0 ]; then
printf
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465864#comment-16465864
]
ASF GitHub Bot commented on FLINK-9073:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465876#comment-16465876
]
ASF GitHub Bot commented on FLINK-9305:
---
GitHub user NicoK opened a pull request:
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5963
[FLINK-9305][s3] also register flink-s3-fs-hadoop's factory for the s3a://
scheme
## What is the purpose of the change
For enhanced user experience, we should also register our Hadoop
[
https://issues.apache.org/jira/browse/FLINK-9235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465888#comment-16465888
]
ASF GitHub Bot commented on FLINK-9235:
---
Github user aljoscha commented on the issue:
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/5953
hey, it's working now ð
cc @zentol
---
Alex Chen created FLINK-9307:
Summary: Running flink program doesn't print infos in console any
more
Key: FLINK-9307
URL: https://issues.apache.org/jira/browse/FLINK-9307
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465828#comment-16465828
]
ASF GitHub Bot commented on FLINK-9304:
---
Github user StefanRRichter commented on the issue:
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/5962
[FLINK-9304] Timer service shutdown should not stop if interrupted
## What is the purpose of the change
This PR prevents that interruption prematurely stops the shutdown of the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5962
CC @tillrohrmann
---
[
https://issues.apache.org/jira/browse/FLINK-9125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465841#comment-16465841
]
ASF GitHub Bot commented on FLINK-9125:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/5933
merging.
---
[
https://issues.apache.org/jira/browse/FLINK-9309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang reassigned FLINK-9309:
---
Assignee: vinoyang
> Recommend HA setup on Production Readiness Checklist
>
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/5926
LGTM ð
---
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465923#comment-16465923
]
Triones Deng commented on FLINK-9303:
-
[~tzulitai] i am interested in this issue. in you jira. there
[
https://issues.apache.org/jira/browse/FLINK-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Chen updated FLINK-9307:
-
Issue Type: Improvement (was: Bug)
> Running flink program doesn't print infos in console any more
>
[
https://issues.apache.org/jira/browse/FLINK-9307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alex Chen updated FLINK-9307:
-
Priority: Critical (was: Major)
> Running flink program doesn't print infos in console any more
>
Fabian Hueske created FLINK-9309:
Summary: Recommend HA setup on Production Readiness Checklist
Key: FLINK-9309
URL: https://issues.apache.org/jira/browse/FLINK-9309
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-9073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465869#comment-16465869
]
ASF GitHub Bot commented on FLINK-9073:
---
Github user StefanRRichter commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465880#comment-16465880
]
ASF GitHub Bot commented on FLINK-8971:
---
Github user StefanRRichter commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465949#comment-16465949
]
ASF GitHub Bot commented on FLINK-9138:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5860
Hi @glaksh100,
I just noticed that the bucket closing check is only done when a record is
written. Hence, inactive buckets might not get closed in time if a larger
inactive bucket interval
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/5923
Honestly, I did not find the proposed change too convincing either due to
the additional branch into bounded vs. unbounded partitions which caused the
variable names to be wrong in the unbounded case.
[
https://issues.apache.org/jira/browse/FLINK-9284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465962#comment-16465962
]
Triones Deng commented on FLINK-9284:
-
[~Zentol] see the example link. there are two place where -m
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-8999:
---
Assignee: (was: mingleizhang)
> Ensure the job has an operator with operator state.
>
[
https://issues.apache.org/jira/browse/FLINK-7917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466010#comment-16466010
]
ASF GitHub Bot commented on FLINK-7917:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5777
cc @zentol @GJL @tzulitai this PR takes a long time, please review it
thanks.
---
[
https://issues.apache.org/jira/browse/FLINK-7897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466011#comment-16466011
]
ASF GitHub Bot commented on FLINK-7897:
---
Github user yanghua commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466037#comment-16466037
]
Ted Yu commented on FLINK-9303:
---
{code}
+ if (!removedPartitions.isEmpty()) {
+
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466051#comment-16466051
]
ASF GitHub Bot commented on FLINK-8237:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465955#comment-16465955
]
ASF GitHub Bot commented on FLINK-9253:
---
Github user NicoK commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466005#comment-16466005
]
ASF GitHub Bot commented on FLINK-8999:
---
Github user zhangminglei commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-9282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466002#comment-16466002
]
ASF GitHub Bot commented on FLINK-9282:
---
Github user W4anD0eR96 commented on a diff in the pull
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5798
cc @zentol @GJL @tzulitai this PR takes a long time, please review thanks~
---
[
https://issues.apache.org/jira/browse/FLINK-8999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466007#comment-16466007
]
ASF GitHub Bot commented on FLINK-8999:
---
Github user zhangminglei closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-7001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466014#comment-16466014
]
Rong Rong commented on FLINK-7001:
--
Thanks [~pgrulich], This is definitely a great solution when handling
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466048#comment-16466048
]
ASF GitHub Bot commented on FLINK-8690:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466047#comment-16466047
]
ASF GitHub Bot commented on FLINK-8500:
---
Github user FredTing commented on a diff in the pull
Github user FredTing commented on a diff in the pull request:
https://github.com/apache/flink/pull/5958#discussion_r186462871
--- Diff:
flink-connectors/flink-connector-kafka-0.10/src/main/java/org/apache/flink/streaming/connectors/kafka/internal/Kafka010Fetcher.java
---
@@ -78,6
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5940
Thanks for the update @walterddr.
The PR is good to merge.
---
[
https://issues.apache.org/jira/browse/FLINK-9261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Yao reassigned FLINK-9261:
---
Assignee: Gary Yao
> Regression - Flink CLI and Web UI not working when SSL is enabled
>
[
https://issues.apache.org/jira/browse/FLINK-9303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465996#comment-16465996
]
Edward Rojas commented on FLINK-9303:
-
Hello,
I reported the issue on the mailing list.
I have being
[
https://issues.apache.org/jira/browse/FLINK-8946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16465999#comment-16465999
]
ASF GitHub Bot commented on FLINK-8946:
---
Github user yanghua commented on the issue:
Github user zhangminglei commented on the issue:
https://github.com/apache/flink/pull/5890
@tzulitai Yes. Thanks ~ . I totally agree. I have been so busy these days.
I will close this PR.
---
Github user W4anD0eR96 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5957#discussion_r186453573
--- Diff: docs/quickstart/setup_quickstart.md ---
@@ -233,29 +239,17 @@ window of processing time, as long as words are
floating in.
* First
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/5927
Thanks for the update @pavel-shvetsov-git.
+1 to merge
---
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5869
cc @zentol would you like to have a look?
---
Github user zhangminglei closed the pull request at:
https://github.com/apache/flink/pull/5890
---
[
https://issues.apache.org/jira/browse/FLINK-9064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466020#comment-16466020
]
ASF GitHub Bot commented on FLINK-9064:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/5773
cc @zentol @GJL @tzulitai please review thanks~
---
[
https://issues.apache.org/jira/browse/FLINK-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-8690.
Resolution: Implemented
Fix Version/s: 1.6.0
Implemented for 1.6.0 with
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466381#comment-16466381
]
ASF GitHub Bot commented on FLINK-8255:
---
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/5961#discussion_r186477977
--- Diff:
flink-java/src/main/java/org/apache/flink/api/java/functions/SelectByMinFunction.java
---
@@ -41,7 +41,7 @@
* is regarded in the reduce
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186528901
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/util/typeutils/FieldAccessorTest.java
---
@@ -368,4 +369,23 @@ public void
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186484649
--- Diff:
flink-java/src/test/java/org/apache/flink/api/java/operator/MaxByOperatorTest.java
---
@@ -230,4 +235,43 @@ public String toString() {
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/5961#discussion_r186527205
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -157,15 +156,15 @@ public T set(T record,
[
https://issues.apache.org/jira/browse/FLINK-8255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16466384#comment-16466384
]
ASF GitHub Bot commented on FLINK-8255:
---
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/5961#discussion_r186527277
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
---
@@ -197,7 +196,7 @@ public T set(T record, F
Stephan Ewen created FLINK-9313:
---
Summary: Enable mutual authentication for RPC (akka)
Key: FLINK-9313
URL: https://issues.apache.org/jira/browse/FLINK-9313
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske reassigned FLINK-8237:
Assignee: Pavel Shvetsov
> BucketingSink throws NPE when Writer.duplicate returns null
>
101 - 200 of 275 matches
Mail list logo
