Github user vasia commented on the issue:
https://github.com/apache/flink/pull/2842
Hi @twalthr, thank you so much for looking into this. I'll create an issue
for functions with > 2 inputs.
I have replaced `createTypeInfo` with `getMapReturnTypes` where possible,
but I'm getting a
[
https://issues.apache.org/jira/browse/FLINK-5097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728099#comment-15728099
]
ASF GitHub Bot commented on FLINK-5097:
---
Github user vasia commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728171#comment-15728171
]
Tzu-Li (Gordon) Tai commented on FLINK-4905:
Hi [~Andrew Efimov],
Sorry for t
[
https://issues.apache.org/jira/browse/FLINK-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728171#comment-15728171
]
Tzu-Li (Gordon) Tai edited comment on FLINK-4905 at 12/7/16 8:58 AM:
---
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5017:
---
Priority: Major (was: Blocker)
> Introduce WatermarkStatus stream element to allow fo
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728178#comment-15728178
]
Tzu-Li (Gordon) Tai commented on FLINK-5017:
I'm changing the priority of this
[
https://issues.apache.org/jira/browse/FLINK-5017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Tzu-Li (Gordon) Tai updated FLINK-5017:
---
Fix Version/s: (was: 1.2.0)
> Introduce WatermarkStatus stream element to allow fo
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728216#comment-15728216
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2729
LGTM now. Maybe somebody else could also approve the additions to the
public API and then merge, @aljoscha or @tillrohrmann maybe?
---
If your project is set up for it, you can reply to this
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2781
Thanks a lot for the review, I addressed the comments (except for some
tests which will still follow in a different commit). Looking for approval on
the changes/rebase and somebody to merge th
[
https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728225#comment-15728225
]
ASF GitHub Bot commented on FLINK-5041:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728241#comment-15728241
]
ASF GitHub Bot commented on FLINK-5041:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2781
@StefanRRichter ist there already an issue for adding a very elaborate test
for this that restores from a Flink 1.1 savepoint? If not, could you please
create one.
Very good work, by the wa
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2781
Thanks @aljoscha ! I will talk with @twalthr about this today and will
create a JIRA after we agreed upon the scope and way of testing this. Expect a
JIRA later today.
---
If your project is
[
https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728247#comment-15728247
]
ASF GitHub Bot commented on FLINK-5041:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728253#comment-15728253
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user aljoscha commented on the issue
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2729
I realise I'm a bit late but I think we should not add a config that allows
Scala Object functions. The only case where this makes sense if you have a
pipeline with parallelism 1. Allowing users to
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728258#comment-15728258
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user StefanRRichter commented on the
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2729
Agreed, this partially defeats the purpose, because you can "forget" this
switch and create problems that are hard to debug.
---
If your project is set up for it, you can reply to this email
[
https://issues.apache.org/jira/browse/FLINK-5035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728267#comment-15728267
]
Stefan Richter commented on FLINK-5035:
---
That is correct. I think we actually need t
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728278#comment-15728278
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user Renkai commented on the issue:
Github user Renkai commented on the issue:
https://github.com/apache/flink/pull/2729
Hi, @aljoscha I think the case make sense not only when parallelsim is
1,but also users knows the code would be execute in parallel and the code is
thread safe and they may want to reduce some resourc
[
https://issues.apache.org/jira/browse/FLINK-3848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728290#comment-15728290
]
ASF GitHub Bot commented on FLINK-3848:
---
Github user tonycox commented on the issue:
Github user tonycox commented on the issue:
https://github.com/apache/flink/pull/2810
Hi @fhueske and @KurtYoung I totally agree with the plan
---
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
[
https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728297#comment-15728297
]
Kurt Young commented on FLINK-5266:
---
You mean "Aggregate.construct()"?
Hmm..I didn't t
[
https://issues.apache.org/jira/browse/FLINK-5266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728318#comment-15728318
]
Fabian Hueske commented on FLINK-5266:
--
Yes, I meant {{Aggregate.construct()}}. Sorry
Fabian Hueske created FLINK-5268:
Summary: Split TableProgramsTestBase into
TableProgramsCollectionTestBase and TableProgramsClusterTestBase
Key: FLINK-5268
URL: https://issues.apache.org/jira/browse/FLINK-5268
[
https://issues.apache.org/jira/browse/FLINK-3656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-3656:
-
Description:
The {{flink-table}} component consists of
several APIs
* Scala-embedded T
Fabian Hueske created FLINK-5269:
Summary: Convert string-based Table API tests into unit tests
Key: FLINK-5269
URL: https://issues.apache.org/jira/browse/FLINK-5269
Project: Flink
Issue Type
Fabian Hueske created FLINK-5270:
Summary: Refactor the batch Scala-expression Table API tests
Key: FLINK-5270
URL: https://issues.apache.org/jira/browse/FLINK-5270
Project: Flink
Issue Type:
Fabian Hueske created FLINK-5271:
Summary: Refactor the batch SQL tests
Key: FLINK-5271
URL: https://issues.apache.org/jira/browse/FLINK-5271
Project: Flink
Issue Type: Sub-task
Com
Fabian Hueske created FLINK-5272:
Summary: Refactor the stream Scala-expression Table API tests
Key: FLINK-5272
URL: https://issues.apache.org/jira/browse/FLINK-5272
Project: Flink
Issue Type
[
https://issues.apache.org/jira/browse/FLINK-5271?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Fabian Hueske updated FLINK-5271:
-
Description:
Most tests of the batch SQL tests are full-blown integration tests which are
rather
Fabian Hueske created FLINK-5273:
Summary: Refactor stream SQL tests
Key: FLINK-5273
URL: https://issues.apache.org/jira/browse/FLINK-5273
Project: Flink
Issue Type: Sub-task
Compon
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nikolay Vasilishin reassigned FLINK-3850:
-
Assignee: Nikolay Vasilishin
> Add forward field annotations to DataSet operators
[
https://issues.apache.org/jira/browse/FLINK-5002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728590#comment-15728590
]
ASF GitHub Bot commented on FLINK-5002:
---
Github user MayerRoman commented on the iss
Github user MayerRoman commented on the issue:
https://github.com/apache/flink/pull/2865
Please check changes.
I removed the test and add a check in method.
---
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 pro
Github user aljoscha commented on the issue:
https://github.com/apache/flink/pull/2729
The problem is that this doesn't even work if the user correctly implements
a thread safe UDF. If the UDF is an object then things such as the
`RuntimeContext` will be the same for different subtask
[
https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728598#comment-15728598
]
ASF GitHub Bot commented on FLINK-4883:
---
Github user aljoscha commented on the issue
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728604#comment-15728604
]
Fabian Hueske commented on FLINK-3850:
--
Thanks for picking up this issue [~nvasilishi
Ufuk Celebi created FLINK-5274:
--
Summary: LocalInputChannel throws NPE if partition reader is
released
Key: FLINK-5274
URL: https://issues.apache.org/jira/browse/FLINK-5274
Project: Flink
Issue
Ufuk Celebi created FLINK-5275:
--
Summary: InputChanelDeploymentDescriptors throws misleading
Exception if producer failed/cancelled
Key: FLINK-5275
URL: https://issues.apache.org/jira/browse/FLINK-5275
P
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2955
[backport] Improve some follow up exceptions
Improves follow up Exceptions when the job failed in a different place:
1) Check partition state if returned buffer is null in `LocalInputChannel`.
2)
Ufuk Celebi created FLINK-5276:
--
Summary: ExecutionVertex archiving can throw NPE with many
previous attempts
Key: FLINK-5276
URL: https://issues.apache.org/jira/browse/FLINK-5276
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5042?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5042.
--
Resolution: Implemented
Fix Version/s: 1.2.0
Implemented in af3bf83 (master).
> Convert old save
[
https://issues.apache.org/jira/browse/FLINK-5043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5043.
--
Resolution: Implemented
Fix Version/s: 1.2.0
Implemented in af3bf83 (master).
> Converting keyed
[
https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728719#comment-15728719
]
ASF GitHub Bot commented on FLINK-5041:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728721#comment-15728721
]
Ufuk Celebi commented on FLINK-5041:
Subtasks FLINK-5042 and FLINK-5043 implemented in
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2781
---
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
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2954
Merged in c024b0b6cae16a0b668d864c77e923820c262087 but forgot to include
the "This closes #2954" message in the commit, could you close the PR?
---
If your project is set up for it, you can reply to thi
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5276:
---
Fix Version/s: (was: 1.2.0)
> ExecutionVertex archiving can throw NPE with many previous attempts
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi updated FLINK-5276:
---
Description:
I saw a NPE while archiving a ExecutionVertex:
{code}
execution graph org.apache.flink.ru
GitHub user wuchong opened a pull request:
https://github.com/apache/flink/pull/2956
[FLINK-5223] [doc] Add documentation of UDTF in Table API & SQL
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi reassigned FLINK-5276:
--
Assignee: Ufuk Celebi (was: Stefan Richter)
> ExecutionVertex archiving can throw NPE with man
[
https://issues.apache.org/jira/browse/FLINK-5223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728747#comment-15728747
]
ASF GitHub Bot commented on FLINK-5223:
---
GitHub user wuchong opened a pull request:
GitHub user uce opened a pull request:
https://github.com/apache/flink/pull/2957
[FLINK-5276] [eg] Check for null when archiving prior execution attempts
The `EvictingBoundedList` returns the default value for all evicted
elements. This could lead to NPE when archiving an `Execution
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728761#comment-15728761
]
ASF GitHub Bot commented on FLINK-5276:
---
GitHub user uce opened a pull request:
Github user StefanRRichter commented on the issue:
https://github.com/apache/flink/pull/2957
LGTM +1
---
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 ex00 opened a pull request:
https://github.com/apache/flink/pull/2958
[FLINK-4704] Move Table API to org.apache.flink.table
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into consideration.
If your ch
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728763#comment-15728763
]
ASF GitHub Bot commented on FLINK-5276:
---
Github user StefanRRichter commented on the
[
https://issues.apache.org/jira/browse/FLINK-4704?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728764#comment-15728764
]
ASF GitHub Bot commented on FLINK-4704:
---
GitHub user ex00 opened a pull request:
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728834#comment-15728834
]
Nikolay Vasilishin commented on FLINK-3850:
---
Hi, [~fhueske]!
I've read a topic
Nico Kruber created FLINK-5277:
--
Summary: missing unit test for ensuring ResultPartition#add always
recycles buffers
Key: FLINK-5277
URL: https://issues.apache.org/jira/browse/FLINK-5277
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-5277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Nico Kruber reassigned FLINK-5277:
--
Assignee: Nico Kruber
> missing unit test for ensuring ResultPartition#add always recycles buff
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/2805#discussion_r91306180
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
---
@@ -131,35 +132,30 @@ private void sendToTarget(T re
[
https://issues.apache.org/jira/browse/FLINK-5059?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15728924#comment-15728924
]
ASF GitHub Bot commented on FLINK-5059:
---
Github user NicoK commented on a diff in th
Till Rohrmann created FLINK-5278:
Summary: Improve Task and checkpoint logging
Key: FLINK-5278
URL: https://issues.apache.org/jira/browse/FLINK-5278
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-3850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729014#comment-15729014
]
Fabian Hueske commented on FLINK-3850:
--
The annotations do not need to be code genera
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2653
Thanks. 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
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729081#comment-15729081
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user twalthr commented on the issue:
Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/2653
---
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-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729094#comment-15729094
]
ASF GitHub Bot commented on FLINK-4469:
---
Github user asfgit closed the pull request
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729109#comment-15729109
]
ASF GitHub Bot commented on FLINK-5276:
---
Github user uce closed the pull request at:
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/2957
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-5276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5276.
--
Resolution: Fixed
Fixed in 75b48e (release-1.1)
> ExecutionVertex archiving can throw NPE with many pre
[
https://issues.apache.org/jira/browse/FLINK-5275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5275.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
4410c04 (master), 4526005 (releas
Github user mindprince commented on the issue:
https://github.com/apache/flink/pull/2954
Thanks!
---
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
Github user uce closed the pull request at:
https://github.com/apache/flink/pull/2955
---
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 enabled
Github user mindprince closed the pull request at:
https://github.com/apache/flink/pull/2954
---
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-5274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ufuk Celebi closed FLINK-5274.
--
Resolution: Fixed
Fix Version/s: 1.1.4
1.2.0
555a687 (master), 1b472d2 (releas
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2959
[FLINK-5278] Improve task and checkpoint related logging
Improve logging of Task and checkpoint logic.
cc @uce
You can merge this pull request into a Git repository by running:
$
[
https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729152#comment-15729152
]
ASF GitHub Bot commented on FLINK-5278:
---
GitHub user tillrohrmann opened a pull requ
GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2960
[backport] [FLINK-5278] Improve task and checkpoint related logging
Backport of #2959 for release-1.1.
Improve logging of Task and checkpoint logic.
cc @uce
You can merge thi
[
https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729153#comment-15729153
]
ASF GitHub Bot commented on FLINK-5278:
---
GitHub user tillrohrmann opened a pull requ
Github user mindprince commented on the issue:
https://github.com/apache/flink/pull/2951
Also, this PR is open but the change is already there 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 doe
Github user mxm commented on the issue:
https://github.com/apache/flink/pull/2951
Sorry, I missed your comment. We can open another PR to clarify that!
---
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
Github user mxm closed the pull request at:
https://github.com/apache/flink/pull/2951
---
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 enabled
[
https://issues.apache.org/jira/browse/FLINK-4469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Timo Walther resolved FLINK-4469.
-
Resolution: Fixed
Fix Version/s: 1.2.0
Fixed in 684defbf33168e34657bc1a25607adb53be248c5.
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2913
I removed the `findExecutionAttemptWithId` and only check the latest
attempt. If that does not match the expected producer attempt, I answer with a
`PartitionProducerDisposedException` to which the reque
[
https://issues.apache.org/jira/browse/FLINK-5114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729209#comment-15729209
]
ASF GitHub Bot commented on FLINK-5114:
---
Github user uce commented on the issue:
Ufuk Celebi created FLINK-5279:
--
Summary: Improve error message when trying to access keyed state
in non-keyed operator
Key: FLINK-5279
URL: https://issues.apache.org/jira/browse/FLINK-5279
Project: Flin
Github user uce commented on the issue:
https://github.com/apache/flink/pull/2960
Changes look 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 this feature
enabled and
[
https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729278#comment-15729278
]
ASF GitHub Bot commented on FLINK-5278:
---
Github user uce commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-5278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729286#comment-15729286
]
Ufuk Celebi commented on FLINK-5278:
Merged in b046038 (release-1.1). Merge for master
Fabian Hueske created FLINK-5280:
Summary: Extend TableSource to support nested data
Key: FLINK-5280
URL: https://issues.apache.org/jira/browse/FLINK-5280
Project: Flink
Issue Type: Improveme
Fabian Hueske created FLINK-5281:
Summary: Extend KafkaJsonTableSources to support nested data
Key: FLINK-5281
URL: https://issues.apache.org/jira/browse/FLINK-5281
Project: Flink
Issue Type:
Github user twalthr commented on the issue:
https://github.com/apache/flink/pull/2919
Thanks for reviewing my PR. I hope I addressed all your comments.
---
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
[
https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729389#comment-15729389
]
ASF GitHub Bot commented on FLINK-4554:
---
Github user twalthr commented on the issue:
[
https://issues.apache.org/jira/browse/FLINK-4554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15729394#comment-15729394
]
ASF GitHub Bot commented on FLINK-4554:
---
Github user fhueske commented on the issue:
Github user fhueske commented on the issue:
https://github.com/apache/flink/pull/2919
Thanks for the update.
+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
enab
1 - 100 of 138 matches
Mail list logo
