GitHub user ASRagab opened a pull request:
https://github.com/apache/flink/pull/2261
[FLINK-4226] Typo: Define Keys using Field Expressions example should use
window and not reduce
You can merge this pull request into a Git repository by running:
$ git pull
[
https://issues.apache.org/jira/browse/FLINK-4226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15381087#comment-15381087
]
ASF GitHub Bot commented on FLINK-4226:
---
GitHub user ASRagab opened a pull request:
Ahmad Ragab created FLINK-4226:
--
Summary: Typo: Define Keys using Field Expressions example should
use window and not reduce
Key: FLINK-4226
URL: https://issues.apache.org/jira/browse/FLINK-4226
[
https://issues.apache.org/jira/browse/FLINK-3397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380873#comment-15380873
]
ramkrishna.s.vasudevan commented on FLINK-3397:
---
Thanks for the valuable feedback.
>>This is
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380840#comment-15380840
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user chadnickbok commented on the issue:
Github user chadnickbok commented on the issue:
https://github.com/apache/flink/pull/2260
We haven't yet tested this - I was getting a head-start on opening the pull
request because I didn't realize you'd be so responsive!
Plan is to migrate some code over to the latest
Github user chadnickbok commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71068329
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -50,8
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380839#comment-15380839
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user chadnickbok commented on a diff in the pull
Suminda Dharmasena created FLINK-4225:
-
Summary: ML On Streaming Operating in Continuous and Micro Backed
Mode
Key: FLINK-4225
URL: https://issues.apache.org/jira/browse/FLINK-4225
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4224:
--
Description:
When submitting the job below through the web interface to a local flink
cluster:
[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4224:
--
Summary: Exception after successful execution os job submitted through the
web interface.
[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4224:
--
Description:
When submitting the job below through the web interface to a local flink
cluster:
[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4224:
--
Description:
When submitting the job below through the web interface to a local flink
cluster:
[
https://issues.apache.org/jira/browse/FLINK-4224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kostas Kloudas updated FLINK-4224:
--
Description:
When submitting the job below through the web interface to a local flink
cluster:
Kostas Kloudas created FLINK-4224:
-
Summary: Exception after successful execution when submitting job
through the web interface.
Key: FLINK-4224
URL: https://issues.apache.org/jira/browse/FLINK-4224
[
https://issues.apache.org/jira/browse/FLINK-1267?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380688#comment-15380688
]
Greg Hogan commented on FLINK-1267:
---
I will work on writing a FLIP for this feature.
> Add crossGroup
[
https://issues.apache.org/jira/browse/FLINK-3910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-3910.
-
Resolution: Duplicate
> New self-join operator
> --
>
> Key:
[
https://issues.apache.org/jira/browse/FLINK-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380669#comment-15380669
]
ASF GitHub Bot commented on FLINK-2125:
---
Github user delding commented on the issue:
Github user delding commented on the issue:
https://github.com/apache/flink/pull/2233
Hi, I have updated the PR as @StephanEwen suggested, adding two new methods
named socketTextStream that take string delimiter as parameter and delegating
the old method to the new one
---
If your
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380589#comment-15380589
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on the issue:
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2260
@chadnickbok Thank you very much for opening a PR for this, I think this is
definitely a good add to the connector's config options.
Have you tested this new credential option in a AWS
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380587#comment-15380587
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062495
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -50,8
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380586#comment-15380586
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user chadnickbok commented on a diff in the pull
Github user chadnickbok commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062411
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380582#comment-15380582
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on a diff in the pull
Github user chadnickbok commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062384
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -26,7 +26,7 @@ specific language governing permissions and limitations
under the License.
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380583#comment-15380583
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user chadnickbok commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062382
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/config/AWSConfigConstants.java
---
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380580#comment-15380580
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user chadnickbok commented on a diff in the pull
Github user chadnickbok commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062357
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -50,8
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380576#comment-15380576
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on a diff in the pull
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062324
--- Diff: docs/apis/streaming/connectors/kinesis.md ---
@@ -26,7 +26,7 @@ specific language governing permissions and limitations
under the License.
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/2260#discussion_r71062232
--- Diff:
flink-streaming-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/AWSUtil.java
---
@@ -50,8
[
https://issues.apache.org/jira/browse/FLINK-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15380570#comment-15380570
]
ASF GitHub Bot commented on FLINK-4222:
---
Github user tzulitai commented on a diff in the pull
35 matches
Mail list logo
