Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4150
ok, I kind of figured out what `promoteTransitiveDependencies` means.
I removed explicit dependencies of httpclient and httpcore from `pom.xml`,
and made sure http-components are shaded to
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085284#comment-16085284
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on the issu
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085277#comment-16085277
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4150#discussion_r127139879
--- Diff: flink-connectors/flink-connector-kinesis/pom.xml ---
@@ -56,6 +58,18 @@ under the License.
+
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085268#comment-16085268
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on a diff i
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/4150#discussion_r127138994
--- Diff: flink-connectors/flink-connector-kinesis/pom.xml ---
@@ -56,6 +58,18 @@ under the License.
+
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
sunjincheng closed FLINK-7126.
--
Resolution: Fixed
Fixed in c8ca31aba083304117ed527c5c80cb9ede2b81bd
> Support Distinct for Stream SQL
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085242#comment-16085242
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user tzulitai commented on a diff in
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4150#discussion_r127135589
--- Diff: flink-connectors/flink-connector-kinesis/pom.xml ---
@@ -56,6 +58,18 @@ under the License.
+
[
https://issues.apache.org/jira/browse/FLINK-7100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085234#comment-16085234
]
ASF GitHub Bot commented on FLINK-7100:
---
Github user zjureel commented on the issue:
Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4307
@zentol Thank you for your review, I have fix the problems you metioned as
follows:
1. rename `TaskExecutorMetricsInitializer` to `MetricUtils`
2. move `taskManagerMetricGroup.close()` from `d
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085233#comment-16085233
]
ASF GitHub Bot commented on FLINK-5541:
---
GitHub user zhangminglei opened a pull requ
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/4315
[FLINK-5541] Missing null check for localJar in FlinkSubmitter#submitâ¦
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/zhangminglei/flink
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-5541:
---
Assignee: mingleizhang
> Missing null check for localJar in FlinkSubmitter#submitTopology()
>
[
https://issues.apache.org/jira/browse/FLINK-7169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085214#comment-16085214
]
Yueting Chen commented on FLINK-7169:
-
I am going to work on this, but I would like to
[
https://issues.apache.org/jira/browse/FLINK-7126?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085212#comment-16085212
]
ASF GitHub Bot commented on FLINK-7126:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4279
---
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 enab
Yueting Chen created FLINK-7169:
---
Summary: Support AFTER MATCH SKIP function in CEP library API
Key: FLINK-7169
URL: https://issues.apache.org/jira/browse/FLINK-7169
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-7137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085179#comment-16085179
]
ASF GitHub Bot commented on FLINK-7137:
---
GitHub user walterddr opened a pull request
GitHub user walterddr opened a pull request:
https://github.com/apache/flink/pull/4314
[FLINK-7137] [table] Flink TableAPI supports nested CompositeType mapped to
nullable calcite RelDataType by default
You can merge this pull request into a Git repository by running:
$ git p
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085159#comment-16085159
]
mingleizhang commented on FLINK-5541:
-
Thanks Ted report this, I wil take a look.
> M
[
https://issues.apache.org/jira/browse/FLINK-7168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ruidong Li closed FLINK-7168.
-
Resolution: Duplicate
> Add support for Table API & SQL steam-stream inner/left join
> --
Ruidong Li created FLINK-7168:
-
Summary: Add support for Table API & SQL steam-stream inner/left
join
Key: FLINK-7168
URL: https://issues.apache.org/jira/browse/FLINK-7168
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6105:
---
Assignee: mingleizhang
> Properly handle InterruptedException in HadoopInputFormatBase
>
yuqi created FLINK-7167:
---
Summary: Job can set checkpoint meta directory to cover the system
setting state.checkpoints.dir
Key: FLINK-7167
URL: https://issues.apache.org/jira/browse/FLINK-7167
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085054#comment-16085054
]
mingleizhang edited comment on FLINK-6493 at 7/13/17 2:29 AM:
--
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085052#comment-16085052
]
ASF GitHub Bot commented on FLINK-6888:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085054#comment-16085054
]
mingleizhang commented on FLINK-6493:
-
Actually, Sorry. I dont think null check is ine
[
https://issues.apache.org/jira/browse/FLINK-6888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jark Wu closed FLINK-6888.
--
Resolution: Fixed
Fixed in 59463278a868f37028a3391a9b9505a77584e0f7
> Can not determine TypeInformation of ACC
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4105
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085046#comment-16085046
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user wuchong commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084864#comment-16084864
]
ASF GitHub Bot commented on FLINK-7154:
---
GitHub user greghogan opened a pull request
Github user wuchong commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r127113760
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala
---
@@ -20,28 +20,60 @@ pac
[
https://issues.apache.org/jira/browse/FLINK-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085041#comment-16085041
]
ASF GitHub Bot commented on FLINK-7161:
---
Github user KurtYoung commented on a diff i
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
mingleizhang reassigned FLINK-6493:
---
Assignee: mingleizhang
> Ineffective null check in RegisteredOperatorBackendStateMetaInfo#equ
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/4305#discussion_r127113118
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ---
@@ -843,11 +843,14 @@ private float convertToFloat(Object o, float
[
https://issues.apache.org/jira/browse/FLINK-7153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085038#comment-16085038
]
Sihua Zhou commented on FLINK-7153:
---
Hi, [~fhueske] can you help me to verify the proble
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085030#comment-16085030
]
mingleizhang commented on FLINK-6493:
-
Thanks Ted. {{partitionStateSerializerConfigSna
[
https://issues.apache.org/jira/browse/FLINK-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16085012#comment-16085012
]
ASF GitHub Bot commented on FLINK-7161:
---
Github user greghogan commented on a diff i
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/4305#discussion_r127109325
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ---
@@ -843,11 +843,14 @@ private float convertToFloat(Object o, float
[
https://issues.apache.org/jira/browse/FLINK-6838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6838:
--
Description:
{code}
Tests in error:
RescalingITCase.testSavepointRescalingInKeyedState[1] » JobExecution Job
[
https://issues.apache.org/jira/browse/FLINK-7161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084993#comment-16084993
]
ASF GitHub Bot commented on FLINK-7161:
---
Github user KurtYoung commented on a diff i
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/4305#discussion_r127107209
--- Diff:
flink-core/src/main/java/org/apache/flink/configuration/Configuration.java ---
@@ -843,11 +843,14 @@ private float convertToFloat(Object o, float
[
https://issues.apache.org/jira/browse/FLINK-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-7132.
-
Resolution: Fixed
master: 480ccfb4809871d1a0812442a8e175d82aa186c1
1.3: 668527373a26c29fa8af23296cb423e116
[
https://issues.apache.org/jira/browse/FLINK-5541?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-5541:
--
Description:
{code}
if (localJar == null) {
try {
for (final URL url : ((ContextEnvironm
[
https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan closed FLINK-6731.
-
Resolution: Implemented
master: 9bd491e05120915cbde36d4452e3982fe5d0975f
> Activate strict checkstyle for
[
https://issues.apache.org/jira/browse/FLINK-6105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6105:
--
Description:
When catching InterruptedException, we should throw InterruptedIOException
instead of IOException.
[
https://issues.apache.org/jira/browse/FLINK-6493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ted Yu updated FLINK-6493:
--
Description:
{code}
&& ((partitionStateSerializer == null && ((Snapshot)
obj).getPartitionStateSerializ
[
https://issues.apache.org/jira/browse/FLINK-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084916#comment-16084916
]
ASF GitHub Bot commented on FLINK-7132:
---
Github user asfgit closed the pull request
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4295
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-7132:
--
Affects Version/s: 1.3.2
> Fix BulkIteration parallelism
> -
>
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4283
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-7132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-7132:
--
Fix Version/s: 1.3.2
> Fix BulkIteration parallelism
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6731:
--
Fix Version/s: 1.4.0
> Activate strict checkstyle for flink-tests
>
[
https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Greg Hogan updated FLINK-6731:
--
Affects Version/s: 1.4.0
> Activate strict checkstyle for flink-tests
>
[
https://issues.apache.org/jira/browse/FLINK-6731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084917#comment-16084917
]
ASF GitHub Bot commented on FLINK-6731:
---
Github user asfgit closed the pull request
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4313
Thanks for the fix @greghogan.
I'll merge 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
[
https://issues.apache.org/jira/browse/FLINK-7154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084874#comment-16084874
]
ASF GitHub Bot commented on FLINK-7154:
---
Github user fhueske commented on the issue:
GitHub user greghogan opened a pull request:
https://github.com/apache/flink/pull/4313
[FLINK-7154] [docs] Missing call to build CsvTableSource example
The Java and Scala example code for CsvTableSource create a builder but are
missing the final call to build.
You can merge this pu
Github user tedyu commented on a diff in the pull request:
https://github.com/apache/flink/pull/4260#discussion_r127075409
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/dispatcher/Dispatcher.java
---
@@ -0,0 +1,290 @@
+/*
+ * Licensed to the Apache Softwar
[
https://issues.apache.org/jira/browse/FLINK-7103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084724#comment-16084724
]
ASF GitHub Bot commented on FLINK-7103:
---
Github user tedyu commented on a diff in th
[
https://issues.apache.org/jira/browse/FLINK-7003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084680#comment-16084680
]
Rong Rong commented on FLINK-7003:
--
Probably need to write extensive tests to verify the
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7047.
---
Resolution: Fixed
1.4: 1da93a4c73d48b6635e44214383d27cd3d31fc14
> Reorganize build profiles
>
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4233
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084579#comment-16084579
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user asfgit closed the pull request
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4233
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 wishes so, or if the fea
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/4233#discussion_r127032183
--- Diff: .travis.yml ---
@@ -17,32 +17,45 @@ matrix:
include:
# Always run test groups A and B together
--- End diff --
yup, will r
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084440#comment-16084440
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user zentol commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084441#comment-16084441
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user zentol commented on a diff in t
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4310
Maybe some method Javadoc explaining that would be nice.
From the method name `getAllRecordsFromTopic`, the behaviour isn't that
obvious.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-6951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084258#comment-16084258
]
ASF GitHub Bot commented on FLINK-6951:
---
Github user bowenli86 commented on the issu
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4310
@pnowojski only checking that we're actually not reading the same topic
again in the tests.
So, the change in this PR is just to make sure that in the case we do do
that using the `getAllRecords
Github user pnowojski commented on the issue:
https://github.com/apache/flink/pull/4310
Yes and as far as I know, we are doing this. Why do you ask?
---
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
[
https://issues.apache.org/jira/browse/FLINK-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084248#comment-16084248
]
刘喆 commented on FLINK-7165:
---
When using Flink 1.2.1 for hadoop 2.6 , It work fine. But 1.2.
Github user bowenli86 commented on the issue:
https://github.com/apache/flink/pull/4150
I added http components to dependencies because Hadoop-aws 2.7 depends on
http components 4.2.
```
$ jar -tf flink-connector-kinesis_2.11-1.4-SNAPSHOT.jar | grep apache/http
org/apa
[
https://issues.apache.org/jira/browse/FLINK-7165?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084246#comment-16084246
]
刘喆 commented on FLINK-7165:
---
I have tried the following approaches:
# Try the Flink for Hadoop
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/4312
LGTM! ð
---
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 th
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084202#comment-16084202
]
ASF GitHub Bot commented on FLINK-7143:
---
Github user tzulitai commented on the issue
Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/4301
@StephanEwen
Regarding no-rediscover on restore test:
yes, could say that it is covered in
`KafkaConsumerTestBase.runMultipleSourcesOnePartitionExactlyOnceTest()`. It's
an end-to-end exactly
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084182#comment-16084182
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user rmetzger commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084173#comment-16084173
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on the issue:
https://github.com/apache/flink/pull/4233
I think this looks good.
It's basically a change now restricted to the build system only.
+1 to give it a try on master and see how things go with it.
---
If your project is set up for
[
https://issues.apache.org/jira/browse/FLINK-6550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084180#comment-16084180
]
ASF GitHub Bot commented on FLINK-6550:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-7047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084176#comment-16084176
]
ASF GitHub Bot commented on FLINK-7047:
---
Github user rmetzger commented on a diff in
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/4233#discussion_r126991245
--- Diff: pom.xml ---
@@ -858,32 +856,6 @@ under the License.
-
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/4233#discussion_r126990790
--- Diff: .travis.yml ---
@@ -17,32 +17,45 @@ matrix:
include:
# Always run test groups A and B together
--- End diff --
I think t
[
https://issues.apache.org/jira/browse/FLINK-7141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084151#comment-16084151
]
ASF GitHub Bot commented on FLINK-7141:
---
Github user zentol commented on the issue:
Github user zentol commented on the issue:
https://github.com/apache/flink/pull/4293
Ok, now i agree that we should enable the cache as well.
---
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 t
[
https://issues.apache.org/jira/browse/FLINK-6965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-6965.
---
Resolution: Fixed
1.3: aaa7df55ceb741ca4dd886e8816ddbab58afb078
> Avro is missing snappy depe
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/4287
---
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 enab
[
https://issues.apache.org/jira/browse/FLINK-6232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084140#comment-16084140
]
ASF GitHub Bot commented on FLINK-6232:
---
Github user fhueske commented on a diff in
[
https://issues.apache.org/jira/browse/FLINK-6550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084138#comment-16084138
]
ASF GitHub Bot commented on FLINK-6550:
---
GitHub user zentol opened a pull request:
Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/3715#discussion_r126987096
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/rules/datastream/DataStreamWindowJoinRule.scala
---
@@ -20,28 +20,60 @@ pac
GitHub user zentol opened a pull request:
https://github.com/apache/flink/pull/4312
[FLINK-6550] Reject null OutputTags in Context#collect(OutputTag, X)
@aljoscha what do you think?
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/4301
Do we have a test for the case where there are fewer partitions than
sources so that some sources do not get partitions on restore? To make sure
they do not accidentally re-discover?
---
If you
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/4303
will merge 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 wishes so, or if
[
https://issues.apache.org/jira/browse/FLINK-7131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084118#comment-16084118
]
ASF GitHub Bot commented on FLINK-7131:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-7131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7131.
---
Resolution: Fixed
1.4: 8987df55698b659c241857dadbc175bc786e828a
> Streaming wordcount jar doe
[
https://issues.apache.org/jira/browse/FLINK-7138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler closed FLINK-7138.
---
Resolution: Fixed
1.4: 652206519a0974fadfe4606a385f3cd2ab03a481
> Storm example jars do not c
[
https://issues.apache.org/jira/browse/FLINK-7143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16084110#comment-16084110
]
ASF GitHub Bot commented on FLINK-7143:
---
Github user StephanEwen commented on the is
1 - 100 of 298 matches
Mail list logo
