Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/6252
Thanks for opening this PR @HeartSaVioR! (cc @twalthr)
I thought about this again and I don't think we should make the method
public. The problem is that `Expression` is one of the core
[
https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533515#comment-16533515
]
Stefan Richter commented on FLINK-9736:
---
[~sihuazhou] Is correct, this heap is always initialized
[
https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Stefan Richter closed FLINK-9736.
-
Resolution: Not A Bug
> Potential null reference in KeyGroupPartitionedPriorityQueue#poll()
>
Oleksandr Nitavskyi created FLINK-9762:
--
Summary: CoreOptions.TMP_DIRS wrongly managed on Yarn
Key: FLINK-9762
URL: https://issues.apache.org/jira/browse/FLINK-9762
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533509#comment-16533509
]
ASF GitHub Bot commented on FLINK-8558:
---
GitHub user twalthr opened a pull request:
GitHub user twalthr opened a pull request:
https://github.com/apache/flink/pull/6264
[FLINK-8558] [table] Add unified format interfaces and separate formats
from connectors
## What is the purpose of the change
This PR introduces a format discovery mechanism based on Java
[
https://issues.apache.org/jira/browse/FLINK-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-8558:
--
Labels: pull-request-available (was: )
> Add unified format interfaces and format discovery
>
[
https://issues.apache.org/jira/browse/FLINK-9736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533506#comment-16533506
]
Sihua Zhou commented on FLINK-9736:
---
Hi [~yuzhih...@gmail.com] AFAIK, {{heapOfKeyGroupHeaps}} will
Nico Kruber created FLINK-9761:
--
Summary: Potential buffer leak in PartitionRequestClientHandler
during job failures
Key: FLINK-9761
URL: https://issues.apache.org/jira/browse/FLINK-9761
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber resolved FLINK-9676.
Resolution: Fixed
Fixed via
1.6.0: a9b5579b397b6c56e44e21ebb8b2a6a7e6d8b2d1
1.5.0:
[
https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533480#comment-16533480
]
ASF GitHub Bot commented on FLINK-9743:
---
GitHub user snuyanzin opened a pull request:
GitHub user snuyanzin opened a pull request:
https://github.com/apache/flink/pull/6263
[FLINK-9743][Client] Use correct zip/jar path separator
## What is the purpose of the change
*This PR resolves libraries extraction issue from jars*
## Brief change log
[
https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9743:
--
Labels: pull-request-available (was: )
> PackagedProgram.extractContainedLibraries fails on
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533479#comment-16533479
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6257
---
Github user lamber-ken commented on the issue:
https://github.com/apache/flink/pull/6261
:100:, you are welcome, thank you for your explanation, I'll close this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533470#comment-16533470
]
ASF GitHub Bot commented on FLINK-9759:
---
Github user lamber-ken closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533468#comment-16533468
]
ASF GitHub Bot commented on FLINK-9759:
---
Github user lamber-ken commented on the issue:
Github user lamber-ken closed the pull request at:
https://github.com/apache/flink/pull/6261
---
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther reassigned FLINK-8858:
---
Assignee: Timo Walther (was: Renjie Liu)
> Add support for INSERT INTO in SQL Client
>
Dawid Wysakowicz created FLINK-9760:
---
Summary: Return a single element from extractPatterns
Key: FLINK-9760
URL: https://issues.apache.org/jira/browse/FLINK-9760
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533460#comment-16533460
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6090
@xccui perfect. thank you very much!
---
[
https://issues.apache.org/jira/browse/FLINK-9593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533455#comment-16533455
]
ASF GitHub Bot commented on FLINK-9593:
---
Github user dawidwys commented on the issue:
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/6171
Thanks @kl0u for review. I've addressed points 1 and 3. As the second one
touches some critical parts, let's address it in a separate JIRA.
---
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533453#comment-16533453
]
Renjie Liu commented on FLINK-8858:
---
Hi [~twalthr] That's ok since currently I have no time for that.
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533450#comment-16533450
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user xccui commented on the issue:
Github user xccui commented on the issue:
https://github.com/apache/flink/pull/6090
Hi @twalthr, please give me one more day. I will commit the changes
tomorrow. ð
---
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/6262
[hotfix][filesystem] Remove incorrect equals methods in StreamWriters
This pull request removes incorrect equals methods in `StreamWriterBase`
(and in classes that inherit from it) that were used
[
https://issues.apache.org/jira/browse/FLINK-8858?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533444#comment-16533444
]
Timo Walther commented on FLINK-8858:
-
Hi [~liurenjie1024], would it be ok if I assign this issue to
[
https://issues.apache.org/jira/browse/FLINK-7344?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533442#comment-16533442
]
Congxian Qiu commented on FLINK-7344:
-
Hi, [~yew1eb], are you still working on this, If you don't
[
https://issues.apache.org/jira/browse/FLINK-8863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533440#comment-16533440
]
ASF GitHub Bot commented on FLINK-8863:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/6090
Hi @xccui, sorry for being pushy but when do you think you can update this
PR? The feature freeze is in approx. 1 week and I need to coordinate my
work/reviewing efforts. Let me know if you want me
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533438#comment-16533438
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533439#comment-16533439
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200287796
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200287730
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
GitHub user lamber-ken opened a pull request:
https://github.com/apache/flink/pull/6261
[FLINK-9759] [DOCS] give an right answer about the savepoint restore when
stateless operators be added, deleted etc
## What is the purpose of the change
- fix irrelevant answer about the
[
https://issues.apache.org/jira/browse/FLINK-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533433#comment-16533433
]
ASF GitHub Bot commented on FLINK-9759:
---
GitHub user lamber-ken opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-9759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-9759:
--
Labels: pull-request-available (was: )
> give an irrelevant answer about the savepoint
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533425#comment-16533425
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200283214
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
lamber-ken created FLINK-9759:
-
Summary: give an irrelevant answer about the savepoint restore
when stateless operators be added etc
Key: FLINK-9759
URL: https://issues.apache.org/jira/browse/FLINK-9759
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533409#comment-16533409
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200274433
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533408#comment-16533408
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user NicoK commented on a diff in the pull request:
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200274038
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
[
https://issues.apache.org/jira/browse/FLINK-9352?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533407#comment-16533407
]
ASF GitHub Bot commented on FLINK-9352:
---
Github user yanghua commented on the issue:
Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6092
@tillrohrmann has refactored, please review again. the reason of the travis
error is not because of this PR.
---
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang updated FLINK-9718:
--
Summary: Add enviroment variable in start-scala-shell.sh & flink to enable
remote debug (was: Add
[
https://issues.apache.org/jira/browse/FLINK-9718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Zhang reassigned FLINK-9718:
-
Assignee: Jeff Zhang
> Add enviroment variable in start-scala-shell.sh & flink to enable remote
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533343#comment-16533343
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on the issue:
Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/6257
Thanks for fixing this bug, and we also solve this problem in this way.
This solution seems more lightweight than the way in
[6254](https://github.com/apache/flink/pull/6254), and I also
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1656#comment-1656
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1655#comment-1655
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200252253
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6257#discussion_r200251500
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
---
@@ -251,27 +257,56 @@ private MemorySegment
[
https://issues.apache.org/jira/browse/FLINK-9643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1653#comment-1653
]
Viktor Vlasov commented on FLINK-9643:
--
Thank you for the comment, [~StephanEwen].
Actually, if
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533317#comment-16533317
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-9676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16533316#comment-16533316
]
ASF GitHub Bot commented on FLINK-9676:
---
Github user zhijiangW commented on a diff in the pull
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6254#discussion_r200245464
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -594,22 +626,22 @@ public
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6254#discussion_r200247127
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java
---
@@ -479,6 +508,9 @@ void
[
https://issues.apache.org/jira/browse/FLINK-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-9757:
---
Description:
After [hunspell|http://hunspell.github.io/] run the next typos found
||File||
[
https://issues.apache.org/jira/browse/FLINK-9757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin updated FLINK-9757:
---
Affects Version/s: 1.6.0
1.5.0
1.4.2
> Typos
[
https://issues.apache.org/jira/browse/FLINK-9743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin reassigned FLINK-9743:
--
Assignee: Sergey Nuyanzin
> PackagedProgram.extractContainedLibraries fails on
201 - 265 of 265 matches
Mail list logo
