[
https://issues.apache.org/jira/browse/FLINK-5256?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817549#comment-15817549
]
Anton Mushin commented on FLINK-5256:
-
Thanks for your comment!
I update my [test
[
https://issues.apache.org/jira/browse/FLINK-5431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817437#comment-15817437
]
Alexey Diomin commented on FLINK-5431:
--
comment Till Rohrmann
---
I agree with your proposal to use
Github user xhumanoid commented on the issue:
https://github.com/apache/flink/pull/3089
@aljoscha @rmetzger
---
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
Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/2938
Thanks @twalthr for your hint. It is a bug in my
`DataSetTumbleTimeWindowAggReduceCombineFunction#combine(...)` method, that the
rowtime attribute is dropped when combining.
The collection
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15817257#comment-15817257
]
ASF GitHub Bot commented on FLINK-4692:
---
Github user wuchong commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816780#comment-15816780
]
ASF GitHub Bot commented on FLINK-4917:
---
Github user mtunique commented on the issue:
Github user mtunique commented on the issue:
https://github.com/apache/flink/pull/3087
I am sorry about it.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yassine Marzougui updated FLINK-5320:
-
Fix Version/s: 1.2.0
> Fix result TypeInformation in WindowedStream.fold(ACC,
[
https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yassine Marzougui updated FLINK-5432:
-
Fix Version/s: 1.3.0
1.2.0
> ContinuousFileMonitoringFunction is not
[
https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816697#comment-15816697
]
ASF GitHub Bot commented on FLINK-5432:
---
GitHub user ymarzougui opened a pull request:
GitHub user ymarzougui opened a pull request:
https://github.com/apache/flink/pull/3090
[FLINK-5432] fix nested files enumeration in
ContinuousFileMonitoringFunction
This PR fixes reading nested files when the InputFormat has
NestedFileEnumeration set to true. Nested files were
[
https://issues.apache.org/jira/browse/FLINK-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andreas Kempa-Liehr closed FLINK-3867.
--
Resolution: Fixed
Flink VM has been separated into a new repository
[
https://issues.apache.org/jira/browse/FLINK-3867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816532#comment-15816532
]
ASF GitHub Bot commented on FLINK-3867:
---
Github user kempa-liehr commented on the issue:
Github user kempa-liehr commented on the issue:
https://github.com/apache/flink/pull/2075
I just separated the Flink-VM into a separate repository
[https://github.com/kempa-liehr/DSVMs], such t you can close this pull request.
However, could you arrange to link
[
https://issues.apache.org/jira/browse/FLINK-4396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816509#comment-15816509
]
Steven Ruppert commented on FLINK-4396:
---
I just ran into this today.
Reading:
[
https://issues.apache.org/jira/browse/FLINK-4988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816496#comment-15816496
]
ASF GitHub Bot commented on FLINK-4988:
---
Github user mikedias commented on a diff in the pull
Github user mikedias commented on a diff in the pull request:
https://github.com/apache/flink/pull/2767#discussion_r95480042
--- Diff:
flink-connectors/flink-connector-elasticsearch5/src/main/java/org/apache/flink/streaming/connectors/elasticsearch5/ElasticsearchSink.java
---
@@
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5280.
Resolution: Fixed
Fix Version/s: 1.3.0
1.2.0
Fixed for 1.2 with
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske closed FLINK-5358.
Resolution: Fixed
Fix Version/s: 1.3.0
Implemented for 1.3 with
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5280:
-
Summary: Refactor TableSource (was: Extend TableSource to support nested
data)
> Refactor
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816248#comment-15816248
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user asfgit closed the pull request at:
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816247#comment-15816247
]
ASF GitHub Bot commented on FLINK-5358:
---
Github user asfgit closed the pull request at:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3027
---
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
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/3039
---
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
[
https://issues.apache.org/jira/browse/FLINK-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816172#comment-15816172
]
Pattarawat Chormai commented on FLINK-1737:
---
[~till.rohrmann] should we close this issue?
> Add
[
https://issues.apache.org/jira/browse/FLINK-3903?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816161#comment-15816161
]
Pattarawat Chormai commented on FLINK-3903:
---
[~uce] are you still working on the issue?
>
[
https://issues.apache.org/jira/browse/FLINK-4499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15816125#comment-15816125
]
Ted Yu commented on FLINK-4499:
---
This should be assigned to [~smarthi], right ?
> Introduce findbugs maven
Github user StephanEwen commented on the issue:
https://github.com/apache/flink/pull/3030
Has been merged, closing the pull request...
---
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
Github user StephanEwen closed the pull request at:
https://github.com/apache/flink/pull/3030
---
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
[
https://issues.apache.org/jira/browse/FLINK-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815993#comment-15815993
]
ASF GitHub Bot commented on FLINK-5418:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3073
A better estimate for `ROW` will be merged with #3039. I think the best we
can do for array is to estimate the size of one array element and have some
default array size.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815979#comment-15815979
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user mushketyk commented on the issue:
Github user mushketyk commented on the issue:
https://github.com/apache/flink/pull/3039
Hi @fhueske, @wuchong
Thank you for your reviews and your help with this PR.
I've updated the PR.
---
If your project is set up for it, you can reply to this email and have your
[
https://issues.apache.org/jira/browse/FLINK-5418?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815922#comment-15815922
]
ASF GitHub Bot commented on FLINK-5418:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3073#discussion_r95437867
--- Diff:
flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/FlinkRel.scala
---
@@ -120,6 +120,7 @@ trait FlinkRel {
GitHub user xhumanoid opened a pull request:
https://github.com/apache/flink/pull/3089
remove duplicated tests
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your changes take all of the
[
https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815786#comment-15815786
]
ASF GitHub Bot commented on FLINK-5144:
---
Github user KurtYoung commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815785#comment-15815785
]
ASF GitHub Bot commented on FLINK-5144:
---
Github user KurtYoung commented on a diff in the pull
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3062#discussion_r95427815
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/CorrelateITCase.scala
---
@@ -0,0 +1,68 @@
+/*
+ *
Github user KurtYoung commented on a diff in the pull request:
https://github.com/apache/flink/pull/3062#discussion_r95427718
--- Diff: tools/maven/suppressions.xml ---
@@ -23,6 +23,8 @@ under the License.
"http://www.puppycrawl.com/dtds/suppressions_1_1.dtd;>
Github user kaelumania commented on the issue:
https://github.com/apache/flink/pull/3086
@mxn One drawback using `ENV` might be with docker-compose, see
https://docs.docker.com/compose/compose-file/#/args which states
> You can omit the value when specifying a build argument,
[
https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815559#comment-15815559
]
ASF GitHub Bot commented on FLINK-5296:
---
Github user kl0u commented on the issue:
Github user kl0u commented on the issue:
https://github.com/apache/flink/pull/3075
@aljoscha Thanks for the review!
I will integrate the comments and ping you.
---
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
[
https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815551#comment-15815551
]
ASF GitHub Bot commented on FLINK-5296:
---
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/3075#discussion_r95412039
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingAlignedProcessingTimeWindows.java
---
@@ -0,0 +1,61
[
https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1581#comment-1581
]
ASF GitHub Bot commented on FLINK-5296:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815553#comment-15815553
]
ASF GitHub Bot commented on FLINK-5296:
---
Github user aljoscha commented on a diff in the pull
[
https://issues.apache.org/jira/browse/FLINK-5296?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815556#comment-15815556
]
ASF GitHub Bot commented on FLINK-5296:
---
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/3075#discussion_r95411689
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
---
@@ -977,6 +1012,79 @@ private
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3075#discussion_r95411735
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/BaseAlignedWindowAssigner.java
---
@@ -0,0 +1,71 @@
+/*
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3075#discussion_r95411773
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingAlignedProcessingTimeWindows.java
---
@@ -0,0 +1,61
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3075#discussion_r95411761
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SlidingAlignedProcessingTimeWindows.java
---
@@ -0,0 +1,61
Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3075#discussion_r95412067
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/TumblingAlignedProcessingTimeWindows.java
---
@@ -0,0 +1,53
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95411011
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -28,6 +28,9 @@ if [ "$1" == "jobmanager" ]; then
echo "config file: " && grep
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95411497
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -36,9 +39,9 @@ elif [ "$1" == "taskmanager" ]; then
echo "Starting Task Manager"
Github user mxm commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95410892
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,9 +22,9 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure Flink
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95401803
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,9 +22,9 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3086
For creating tickets, it's actually a requirement from Apache Legal as PR
comments are then automatically added to the associated Jira which documents
the contribution of the code to the project.
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815389#comment-15815389
]
ASF GitHub Bot commented on FLINK-3850:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3040
I will also take a look at it soon. Unfortunetly, the build failed. Could
you have a look at it? I also recommend to change the `TableProgramsTestBase`
from `TestExecutionMode.COLLECTION` to
Timo Walther created FLINK-5441:
---
Summary: Directly allow SQL queries on a Table
Key: FLINK-5441
URL: https://issues.apache.org/jira/browse/FLINK-5441
Project: Flink
Issue Type: New Feature
Ufuk Celebi created FLINK-5440:
--
Summary: Misleading error message when migrating and scaling down
from savepoint
Key: FLINK-5440
URL: https://issues.apache.org/jira/browse/FLINK-5440
Project: Flink
Ufuk Celebi created FLINK-5439:
--
Summary: Adjust max parallelism when migrating
Key: FLINK-5439
URL: https://issues.apache.org/jira/browse/FLINK-5439
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815300#comment-15815300
]
ASF GitHub Bot commented on FLINK-4917:
---
Github user greghogan commented on the issue:
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3087
Per Fabian's comment from the Jira, we should also document the deprecation
in the javadoc with the recommended replacement functionality.
---
If your project is set up for it, you can reply to
[
https://issues.apache.org/jira/browse/FLINK-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yassine Marzougui reassigned FLINK-5432:
Assignee: Yassine Marzougui
> ContinuousFileMonitoringFunction is not monitoring
Ufuk Celebi created FLINK-5438:
--
Summary: Typo in JobGraph generator Exception
Key: FLINK-5438
URL: https://issues.apache.org/jira/browse/FLINK-5438
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815285#comment-15815285
]
ASF GitHub Bot commented on FLINK-5407:
---
GitHub user StefanRRichter opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815287#comment-15815287
]
ASF GitHub Bot commented on FLINK-5407:
---
Github user StefanRRichter commented on the issue:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/3088
cc @aljoscha
---
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,
GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/3088
[FLINK-5407] Fix savepoints for iterative jobs
This PR fixes savepoints for iterative jobs. Savepoints failed with NPE
because the code assumed that operators in an operator chain are never
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2545#discussion_r95386388
--- Diff:
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java
---
@@ -675,38 +673,6 @@ else if (isClassType(t) &&
[
https://issues.apache.org/jira/browse/FLINK-4673?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815277#comment-15815277
]
ASF GitHub Bot commented on FLINK-4673:
---
Github user greghogan commented on a diff in the pull
Ufuk Celebi created FLINK-5437:
--
Summary: Make CheckpointedRestoring error message more detailed
Key: FLINK-5437
URL: https://issues.apache.org/jira/browse/FLINK-5437
Project: Flink
Issue Type:
Ufuk Celebi created FLINK-5436:
--
Summary: UDF state without CheckpointedRestoring can result in
restarting loop
Key: FLINK-5436
URL: https://issues.apache.org/jira/browse/FLINK-5436
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-4917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815258#comment-15815258
]
ASF GitHub Bot commented on FLINK-4917:
---
GitHub user mtunique opened a pull request:
Github user kaelumania commented on the issue:
https://github.com/apache/flink/pull/3086
I am not sure, why the build fails as I am not deeply familiar with the
Java/Scala world.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub
GitHub user mtunique opened a pull request:
https://github.com/apache/flink/pull/3087
[FLINK-4917] Deprecate "CheckpointedAsynchronously" interface
- [x] General
- The pull request references the related JIRA issue ([FLINK-4917]
Deprecate "CheckpointedAsynchronously"
Github user kaelumania commented on the issue:
https://github.com/apache/flink/pull/3086
@greghogan No, I didn't create a Ticket (sorry, I was not sure if this
change justifies a Ticket). But I would love to see a Ticket about an automated
build at DockerHub for Flink.
---
If your
[
https://issues.apache.org/jira/browse/FLINK-4861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815251#comment-15815251
]
ASF GitHub Bot commented on FLINK-4861:
---
Github user greghogan closed the pull request at:
Github user greghogan closed the pull request at:
https://github.com/apache/flink/pull/3000
---
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
Github user kaelumania commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95384257
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,9 +22,9 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure
Github user kaelumania commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95384182
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,9 +22,9 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure
Github user greghogan commented on the issue:
https://github.com/apache/flink/pull/3030
This feature has been merged?
---
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
Github user kaelumania commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95383742
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -36,9 +39,9 @@ elif [ "$1" == "taskmanager" ]; then
echo "Starting Task Manager"
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95382374
--- Diff: flink-contrib/docker-flink/docker-entrypoint.sh ---
@@ -36,9 +39,9 @@ elif [ "$1" == "taskmanager" ]; then
echo "Starting Task Manager"
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/3086#discussion_r95381935
--- Diff: flink-contrib/docker-flink/Dockerfile ---
@@ -22,9 +22,9 @@ FROM java:8-jre-alpine
RUN apk add --no-cache bash snappy
# Configure
[
https://issues.apache.org/jira/browse/FLINK-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815229#comment-15815229
]
Timo Walther commented on FLINK-4604:
-
Any news on this [~anmu]? You could solve this issue
[
https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815217#comment-15815217
]
ASF GitHub Bot commented on FLINK-5144:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3062#discussion_r95381802
--- Diff: tools/maven/suppressions.xml ---
@@ -23,6 +23,8 @@ under the License.
"http://www.puppycrawl.com/dtds/suppressions_1_1.dtd;>
[
https://issues.apache.org/jira/browse/FLINK-5144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815208#comment-15815208
]
ASF GitHub Bot commented on FLINK-5144:
---
Github user twalthr commented on a diff in the pull
Github user twalthr commented on a diff in the pull request:
https://github.com/apache/flink/pull/3062#discussion_r95381307
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/api/scala/batch/sql/CorrelateITCase.scala
---
@@ -0,0 +1,68 @@
+/*
+ *
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815202#comment-15815202
]
ASF GitHub Bot commented on FLINK-5358:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3039
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
[
https://issues.apache.org/jira/browse/FLINK-5280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815203#comment-15815203
]
ASF GitHub Bot commented on FLINK-5280:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/3027
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
[
https://issues.apache.org/jira/browse/FLINK-5358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815183#comment-15815183
]
ASF GitHub Bot commented on FLINK-5358:
---
Github user twalthr commented on the issue:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/3027
+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 have this feature
enabled and wishes so, or if
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2938
@fhueske and I looked into this again. I seems that result depends on the
batch ExecutionEnvironment. I used a regular environment while the test base
uses a CollectionExecutionEnvironment. We don't
[
https://issues.apache.org/jira/browse/FLINK-4692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15815149#comment-15815149
]
ASF GitHub Bot commented on FLINK-4692:
---
Github user twalthr commented on the issue:
1 - 100 of 172 matches
Mail list logo