Github user DmytroShkvyra closed the pull request at:
https://github.com/apache/flink/pull/3502
---
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 wishes so, or if the feature
GitHub user DmytroShkvyra reopened a pull request:
https://github.com/apache/flink/pull/3502
[FLINK-4565] Support for SQL IN operator
[FLINK-4565] Support for SQL IN operator
This PR is a part of work on SQL IN operator in Table API, which implements
IN for literals.
Two cas
Luke Hutchison created FLINK-6019:
-
Summary: Some log4j messages do not have a loglevel field set, so
they can't be suppressed
Key: FLINK-6019
URL: https://issues.apache.org/jira/browse/FLINK-6019
Pro
[
https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dawid Wysakowicz reassigned FLINK-6000:
---
Assignee: Dawid Wysakowicz
> Can not start HA cluster with start-cluster.sh
> ---
[
https://issues.apache.org/jira/browse/FLINK-6019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904680#comment-15904680
]
Luke Hutchison commented on FLINK-6019:
---
Also, these messages do not respond to sett
[
https://issues.apache.org/jira/browse/FLINK-6000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904686#comment-15904686
]
ASF GitHub Bot commented on FLINK-6000:
---
GitHub user dawidwys opened a pull request:
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/3506
[FLINK-6000] Fix starting HA cluster with start-cluster.sh
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/dawidwys/flink flink6000
Alternativ
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3461
Thanks for the PR @haohui.
Looks good to me. +1 to merge
---
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 h
[
https://issues.apache.org/jira/browse/FLINK-5954?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904707#comment-15904707
]
ASF GitHub Bot commented on FLINK-5954:
---
Github user fhueske commented on the issue:
Tao Wang created FLINK-6020:
---
Summary: Blob Server cannot hanlde multiple job sumits(with same
content) parallelly
Key: FLINK-6020
URL: https://issues.apache.org/jira/browse/FLINK-6020
Project: Flink
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3507
[FLINK-6006] [kafka] Always use complete restored state in
FlinkKafkaConsumer
(This PR is the fix of FLINK-6006 for Flink 1.1)
Previously, the Kafka Consumer performs partition list queryi
[
https://issues.apache.org/jira/browse/FLINK-6006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904712#comment-15904712
]
ASF GitHub Bot commented on FLINK-6006:
---
GitHub user tzulitai opened a pull request:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3406
Hi @KurtYoung, you are right. Only `requiredProperties()` would be required
to verify properties.
I thought that the other two methods would be a good way to define the
parameters of the co
[
https://issues.apache.org/jira/browse/FLINK-5859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904724#comment-15904724
]
Fabian Hueske commented on FLINK-5859:
--
Yes, the first changes should be attributed t
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904779#comment-15904779
]
Ufuk Celebi commented on FLINK-5985:
Thanks for taking the time to create the example,
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105362292
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,114 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904797#comment-15904797
]
ASF GitHub Bot commented on FLINK-5890:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-5654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904793#comment-15904793
]
ASF GitHub Bot commented on FLINK-5654:
---
Github user fhueske commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904799#comment-15904799
]
ASF GitHub Bot commented on FLINK-5653:
---
Github user fhueske commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3504
Looks good, merging this...
---
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
[
https://issues.apache.org/jira/browse/FLINK-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904802#comment-15904802
]
ASF GitHub Bot commented on FLINK-6010:
---
Github user StephanEwen commented on the is
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105362031
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,138 @@
+/*
+ * Licens
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105363598
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,114 @@
+/*
+ * Licensed
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3459
Hi @huawei-flink,
most Maven modules in Flink are implemented in either Java or Scala. We
have a few modules (like flink-runtime) which are mixed but didn't make good
experience with this d
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3402
@greghogan you are right, I overlooked the adjusted tests!
This looks like a good fix, please merge!
---
If your project is set up for it, you can reply to this email and have your
reply
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105363822
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/ExternalCatalog.scala
---
@@ -0,0 +1,114 @@
+/*
+ * Licensed
[
https://issues.apache.org/jira/browse/FLINK-5995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904817#comment-15904817
]
ASF GitHub Bot commented on FLINK-5995:
---
Github user StephanEwen commented on the is
Github user vasia commented on the issue:
https://github.com/apache/flink/pull/3431
Thanks! Then, it's good to go from my side.
---
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
en
[
https://issues.apache.org/jira/browse/FLINK-6005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904818#comment-15904818
]
ASF GitHub Bot commented on FLINK-6005:
---
Github user StephanEwen commented on the is
[
https://issues.apache.org/jira/browse/FLINK-5910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904820#comment-15904820
]
ASF GitHub Bot commented on FLINK-5910:
---
Github user vasia commented on the issue:
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3503
Thanks for finding and fixing this, important fix!
It would be great if you could add a test for this, to make sure the bug is
not accidentally re-introduced later by someone. You can fol
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3487
I think this looks good now, merging this...
---
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 fea
[
https://issues.apache.org/jira/browse/FLINK-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904826#comment-15904826
]
ASF GitHub Bot commented on FLINK-5980:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3499
Looks good, merging...
---
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 wishe
Github user dawidwys commented on the issue:
https://github.com/apache/flink/pull/3477
@kl0u could you have a look at this PR?
---
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
ena
[
https://issues.apache.org/jira/browse/FLINK-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904837#comment-15904837
]
Robert Metzger commented on FLINK-5998:
---
[~wheat9] Thanks a lot for assigning that i
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3443
Hi, I commented on your other PR (#3459) about mixing Java and Scala and
how to squash the commits.
Thanks, Fabian
---
If your project is set up for it, you can reply to this email and have
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r105368360
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -419,6 +435,14 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904844#comment-15904844
]
ASF GitHub Bot commented on FLINK-5991:
---
GitHub user tzulitai opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904842#comment-15904842
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on a diff in
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/3508
R: @aljoscha @StefanRRichter
---
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 wi
GitHub user tzulitai opened a pull request:
https://github.com/apache/flink/pull/3508
[FLINK-5991] [state-backend, streaming] Expose Broadcast Operator State
This PR exposes broadcast operator state through the `CheckpointedFunction`
interface, by adding broadcast state access metho
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904846#comment-15904846
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user tzulitai commented on the issue
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3485
Looks good, thanks! Merging this...
---
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
enab
[
https://issues.apache.org/jira/browse/FLINK-5976?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904857#comment-15904857
]
ASF GitHub Bot commented on FLINK-5976:
---
Github user StephanEwen commented on the is
Patrick Lucas created FLINK-6021:
Summary: Downloads page references "Hadoop 1 version" which isn't
an option
Key: FLINK-6021
URL: https://issues.apache.org/jira/browse/FLINK-6021
Project: Flink
Github user tillrohrmann commented on the issue:
https://github.com/apache/flink/pull/2905
I fear that we cannot merge the PR as it is, because it would leave the
`CuratorFramework` client open for some of the components used in the master.
For example, the `WebMonitor` uses the same
[
https://issues.apache.org/jira/browse/FLINK-5190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904864#comment-15904864
]
ASF GitHub Bot commented on FLINK-5190:
---
Github user tillrohrmann commented on the i
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904869#comment-15904869
]
Ufuk Celebi commented on FLINK-5985:
Thanks again for reporting this. You are right, w
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904873#comment-15904873
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5981?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904876#comment-15904876
]
ASF GitHub Bot commented on FLINK-5981:
---
Github user StephanEwen commented on the is
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3484#discussion_r105372676
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java
---
@@ -419,6 +435,14 @@ public voi
[
https://issues.apache.org/jira/browse/FLINK-4460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904878#comment-15904878
]
ASF GitHub Bot commented on FLINK-4460:
---
Github user aljoscha commented on a diff in
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3486#discussion_r105371699
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/net/SSLUtils.java ---
@@ -55,6 +58,42 @@ public static boolean getSSLEnabled(Configuration
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3486
I think this is a good fix.
Is it possible to add some form of test that makes sure the config is
properly applied in all cases? What do you think about adding to the
`SSLUtilsTest` class and
Robert Metzger created FLINK-6022:
-
Summary: Improve support for Avro GenericRecord
Key: FLINK-6022
URL: https://issues.apache.org/jira/browse/FLINK-6022
Project: Flink
Issue Type: Improvemen
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3508
The PR re-introduces methods that have been removed from the public
interface before the release. Reason the remove the methods was that we had too
little time to make a final decision on the
[
https://issues.apache.org/jira/browse/FLINK-5991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904882#comment-15904882
]
ASF GitHub Bot commented on FLINK-5991:
---
Github user StefanRRichter commented on the
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3477
Hi @dawidwys , I will do this in the beginning of next week at the latest.
One thing that I saw is that in the `Pattern` class you do not check for
conflicting configurations e.g. oneToMany and
[
https://issues.apache.org/jira/browse/FLINK-5985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904895#comment-15904895
]
Stefan Richter commented on FLINK-5985:
---
I think the proper solution is based on pre
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904899#comment-15904899
]
Flavio Pompermaier commented on FLINK-6022:
---
HI [~rmetzger], does this apply als
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105377617
--- Diff:
flink-tests/src/test/java/org/apache/flink/test/checkpointing/SavepointITCase.java
---
@@ -736,7 +736,7 @@ public void restoreState(List state) throw
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904915#comment-15904915
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904917#comment-15904917
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105377853
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStream
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105377789
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/KeyedStream.java
---
@@ -114,9 +121,53 @@ public KeyedStream(DataStream
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904918#comment-15904918
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-6022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904920#comment-15904920
]
Robert Metzger commented on FLINK-6022:
---
I think protobuf always works with generate
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105378808
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors() {
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904928#comment-15904928
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-4545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904930#comment-15904930
]
ASF GitHub Bot commented on FLINK-4545:
---
Github user StephanEwen commented on the is
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3480
Did another review - looks good to me!
Merging...
---
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
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105378932
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors() {
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904931#comment-15904931
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on a diff in the
[
https://issues.apache.org/jira/browse/FLINK-5980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Biao Liu resolved FLINK-5980.
-
Resolution: Fixed
> Expose max-parallelism value in RuntimeContext
> -
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904945#comment-15904945
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on a diff in the
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/3501#discussion_r105380399
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/DataStreamTest.java
---
@@ -906,6 +919,256 @@ public void testChannelSelectors() {
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/3218
ok, let's close this PR as the issue is actually deeper than originally
though and can only be fixed with a new heap state backend or by locking for
queryable state queries as well
---
If your projec
[
https://issues.apache.org/jira/browse/FLINK-5642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904953#comment-15904953
]
ASF GitHub Bot commented on FLINK-5642:
---
Github user NicoK closed the pull request a
Github user NicoK closed the pull request at:
https://github.com/apache/flink/pull/3218
---
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 wishes so, or if the feature is enabl
[
https://issues.apache.org/jira/browse/FLINK-5642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15904952#comment-15904952
]
ASF GitHub Bot commented on FLINK-5642:
---
Github user NicoK commented on the issue:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105382341
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,138 @@
+/*
+ * Licensed
Mauro Cortellazzi created FLINK-6023:
Summary: Fix Scala snippet into Process Function (Low-level
Operations) Doc
Key: FLINK-6023
URL: https://issues.apache.org/jira/browse/FLINK-6023
Project: Fli
[
https://issues.apache.org/jira/browse/FLINK-6023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrea Sella reassigned FLINK-6023:
---
Assignee: Andrea Sella
> Fix Scala snippet into Process Function (Low-level Operations) Doc
>
Github user beyond1920 commented on a diff in the pull request:
https://github.com/apache/flink/pull/3406#discussion_r105384191
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/catalog/CatalogTableHelper.scala
---
@@ -0,0 +1,138 @@
+/*
+ * Licens
Github user StephanEwen commented on a diff in the pull request:
https://github.com/apache/flink/pull/3466#discussion_r105389424
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java
---
@@ -97,6 +100,27 @@ public FsStateBackend(String
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905007#comment-15905007
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StephanEwen commented on a diff
[
https://issues.apache.org/jira/browse/FLINK-5715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905015#comment-15905015
]
ASF GitHub Bot commented on FLINK-5715:
---
Github user StefanRRichter commented on a d
Github user StefanRRichter commented on a diff in the pull request:
https://github.com/apache/flink/pull/3466#discussion_r105390074
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java
---
@@ -97,6 +100,27 @@ public FsStateBackend(Str
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3501
Thanks for the thorough review @zentol . I integrated the comments that I
agree with and commented on the rest. If you agree with the changes, I can
merge it.
---
If your project is set up for it, you
[
https://issues.apache.org/jira/browse/FLINK-5874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905022#comment-15905022
]
ASF GitHub Bot commented on FLINK-5874:
---
Github user kl0u commented on the issue:
Github user senorcarbone commented on the issue:
https://github.com/apache/flink/pull/1668
Hey @addisonj.
Sure! You could perhaps review the changes and maybe see how to discard
empty operator states if you are motivated. This is the only pending issue for
this PR. thanks!
---
[
https://issues.apache.org/jira/browse/FLINK-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905044#comment-15905044
]
ASF GitHub Bot commented on FLINK-3257:
---
Github user senorcarbone commented on the i
[
https://issues.apache.org/jira/browse/FLINK-3123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905047#comment-15905047
]
ASF GitHub Bot commented on FLINK-3123:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2687
Rebased on the latest Kafka consumer changes in `master`.
---
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 hav
[
https://issues.apache.org/jira/browse/FLINK-6023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrea Sella reassigned FLINK-6023:
---
Assignee: (was: Andrea Sella)
> Fix Scala snippet into Process Function (Low-level Operat
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3402
@StephanEwen my last comment was ambiguous, I had originally modified a
test and then with yesterday's commit reverted that change and added as a new
test.
Will merge.
---
If your projec
[
https://issues.apache.org/jira/browse/FLINK-5890?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905072#comment-15905072
]
ASF GitHub Bot commented on FLINK-5890:
---
Github user greghogan commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-5808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15905074#comment-15905074
]
ASF GitHub Bot commented on FLINK-5808:
---
GitHub user aljoscha opened a pull request:
GitHub user aljoscha opened a pull request:
https://github.com/apache/flink/pull/3509
[FLINK-5808] Fix Missing verification for setParallelism and
setMaxParallelism
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/aljoscha/flink
1 - 100 of 277 matches
Mail list logo
