[
https://issues.apache.org/jira/browse/FLINK-8217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284616#comment-16284616
]
ASF GitHub Bot commented on FLINK-8217:
---
Github user bowenli86 commented on the issue:
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/5138
@greghogan this is a subtask of FLINK-8192.
@tzulitai What do you think of having a FLIP to FLINK-8192?
---
[
https://issues.apache.org/jira/browse/FLINK-8227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284570#comment-16284570
]
ASF GitHub Bot commented on FLINK-8227:
---
GitHub user dianfu opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/5142
[FLINK-8227] Optimize the performance of SharedBufferSerializer
## What is the purpose of the change
*This pull request optimize the performance of SharedBufferSerializer*
##
Dian Fu created FLINK-8227:
--
Summary: Optimize the performance of SharedBufferSerializer
Key: FLINK-8227
URL: https://issues.apache.org/jira/browse/FLINK-8227
Project: Flink
Issue Type: Bug
[
https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284560#comment-16284560
]
Dian Fu commented on FLINK-8226:
It will cause exceptions such as when serializing the NFA.
{code}
Caused
[
https://issues.apache.org/jira/browse/FLINK-8226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284558#comment-16284558
]
ASF GitHub Bot commented on FLINK-8226:
---
GitHub user dianfu opened a pull request:
GitHub user dianfu opened a pull request:
https://github.com/apache/flink/pull/5141
[FLINK-8226] [cep] Dangling reference generated after NFA clean up timed
out SharedBufferEntry
â¦med out SharedBufferEntry
*Thank you very much for contributing to Apache Flink - we
Dian Fu created FLINK-8226:
--
Summary: Dangling reference generated after NFA clean up timed out
SharedBufferEntry
Key: FLINK-8226
URL: https://issues.apache.org/jira/browse/FLINK-8226
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-7797?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284543#comment-16284543
]
ASF GitHub Bot commented on FLINK-7797:
---
GitHub user xccui opened a pull request:
GitHub user xccui opened a pull request:
https://github.com/apache/flink/pull/5140
[FLINK-7797] [table] Add support for windowed outer joins for streaming
tables
## What is the purpose of the change
This PR adds support for windowed outer joins for streaming tables.
[
https://issues.apache.org/jira/browse/FLINK-8116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16284230#comment-16284230
]
ASF GitHub Bot commented on FLINK-8116:
---
Github user ankitiitb1069 commented on a diff in the pull
Github user ankitiitb1069 commented on a diff in the pull request:
https://github.com/apache/flink/pull/5121#discussion_r155877893
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
---
@@ -34,17 +34,17 @@
* The
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283741#comment-16283741
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5134
I also think being more on the cautious side is actually a good thing.
Given how scared and confused many people and companies are with respect to
open source and accidentally infringement of
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283734#comment-16283734
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5134
@greg I think there is one more requirement by the ASF (not necessarily the
Apache License itself), which is making sure that downstream consumers of
Apache projects are always explicitly aware
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4987#discussion_r155804733
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -757,6 +775,64 @@ public void heartbeatFromResourceManager(final
[
https://issues.apache.org/jira/browse/FLINK-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283732#comment-16283732
]
ASF GitHub Bot commented on FLINK-8029:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283718#comment-16283718
]
ASF GitHub Bot commented on FLINK-8029:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4987#discussion_r155802027
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/metrics/MetricRegistry.java
---
@@ -27,8 +27,6 @@
/**
* Interface for a metric
Github user yew1eb commented on the issue:
https://github.com/apache/flink/pull/5072
@greghogan, I saw the following in the `flink-core` POM:
```
org.xerial.snappy
snappy-java
```
I think this PR just upgrades the snappy-java version
[
https://issues.apache.org/jira/browse/FLINK-7984?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283716#comment-16283716
]
ASF GitHub Bot commented on FLINK-7984:
---
Github user yew1eb commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-8030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283699#comment-16283699
]
ASF GitHub Bot commented on FLINK-8030:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/4988#discussion_r155797999
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/WebMonitorEndpoint.java
---
@@ -0,0 +1,402 @@
+/*
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283657#comment-16283657
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5134
@pnowojski see FLINK-2848 and FLINK-2973. Also the BSD + Patents
conversation along with Flink's dependence on Amazon's Kinesis library
(likewise [Category
[
https://issues.apache.org/jira/browse/FLINK-8192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283523#comment-16283523
]
ASF GitHub Bot commented on FLINK-8192:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/5138
Changes to the public API require a
[FLIP](https://cwiki.apache.org/confluence/display/FLINK/Flink+Improvement+Proposals).
---
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283481#comment-16283481
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155770364
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManagerTest.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283477#comment-16283477
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155770104
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManagerTest.java
---
@@ -0,0 +1,502 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283470#comment-16283470
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155768880
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283413#comment-16283413
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155758219
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotSharingManager.java
---
@@ -0,0 +1,722 @@
+/*
+ * Licensed to the
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283397#comment-16283397
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155754738
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -266,104 +279,367 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283365#comment-16283365
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user StephanEwen commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/5134
@greghogan That may or may not be possible, not 100% sure. Re-distributing
it does certainly not work.
To my current understanding, the Apache guidelines say we would need to
make sure
Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5091#discussion_r155751694
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/slotpool/SlotPool.java
---
@@ -266,104 +279,367 @@ public void
[
https://issues.apache.org/jira/browse/FLINK-7956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283364#comment-16283364
]
ASF GitHub Bot commented on FLINK-7956:
---
Github user GJL commented on a diff in the pull request:
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283318#comment-16283318
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283319#comment-16283319
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in the pull
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155746723
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155746766
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-8220?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283309#comment-16283309
]
ASF GitHub Bot commented on FLINK-8220:
---
Github user pnowojski commented on the issue:
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/5134
It seems like `commons-lang` doesn't have any issues with using `jmh` in
tests: https://commons.apache.org/proper/commons-lang/dependencies.html
However @greghogan do you remember my
[
https://issues.apache.org/jira/browse/FLINK-4812?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283304#comment-16283304
]
ASF GitHub Bot commented on FLINK-4812:
---
Github user aljoscha commented on a diff in the pull
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/5125#discussion_r155742906
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
---
@@ -80,7 +91,10 @@ public void init()
[
https://issues.apache.org/jira/browse/FLINK-8224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283302#comment-16283302
]
ASF GitHub Bot commented on FLINK-8224:
---
GitHub user shuai-xu opened a pull request:
GitHub user shuai-xu opened a pull request:
https://github.com/apache/flink/pull/5139
[FLINK-8224] [runtime] shutdown application when job terminated in job mode
## What is the purpose of the change
This current job cluster entrypoint doesn't call resource manage to
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283293#comment-16283293
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283292#comment-16283292
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in the pull
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155741290
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -721,6 +722,42 @@ abstract class
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155741244
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/TableEnvironment.scala
---
@@ -411,6 +411,7 @@ abstract class
[
https://issues.apache.org/jira/browse/FLINK-8139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16283289#comment-16283289
]
ASF GitHub Bot commented on FLINK-8139:
---
Github user Aegeaner commented on a diff in the pull
Github user Aegeaner commented on a diff in the pull request:
https://github.com/apache/flink/pull/5065#discussion_r155740555
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/api/BatchTableEnvironment.scala
---
@@ -98,7 +98,9 @@ abstract class
Sendoh created FLINK-8225:
-
Summary: Use JsonRowDeserializationSchema without Kafka connector
dependency
Key: FLINK-8225
URL: https://issues.apache.org/jira/browse/FLINK-8225
Project: Flink
Issue
shuai.xu created FLINK-8224:
---
Summary: Should shudownApplication when job terminated in job mode
Key: FLINK-8224
URL: https://issues.apache.org/jira/browse/FLINK-8224
Project: Flink
Issue Type:
61 matches
Mail list logo
