I've got an issue performing joins using Python API in flink-1.1.1. With
this example code get an NPE (below). However, the NPE disappears when the
filter is removed. Is there an error I'm making in this brief example or is
this a Flink bug?
env = get_environment()
env.set_parallelism(1)
I think that this is actually a bug in Flink. I'm cc'ing Chesnay who
originally contributed the Python API. He can probably tell whether
this is a bug in the Python API or Flink ioperator side of things. ;)
On Mon, Aug 15, 2016 at 10:14 PM, davis k wrote:
> I've got an issue performing joins usin
looks like a bug, will look into it. :)
On 16.08.2016 10:29, Ufuk Celebi wrote:
I think that this is actually a bug in Flink. I'm cc'ing Chesnay who
originally contributed the Python API. He can probably tell whether
this is a bug in the Python API or Flink ioperator side of things. ;)
On Mon,
Found the issue, there was a missing tab in the chaining method...
On 16.08.2016 12:12, Chesnay Schepler wrote:
looks like a bug, will look into it. :)
On 16.08.2016 10:29, Ufuk Celebi wrote:
I think that this is actually a bug in Flink. I'm cc'ing Chesnay who
originally contributed the Python
Awesome, thanks Chesnay!
On Wed, Aug 17, 2016 at 2:58 AM, Chesnay Schepler
wrote:
> Found the issue, there was a missing tab in the chaining method...
>
>
> On 16.08.2016 12:12, Chesnay Schepler wrote:
>
>> looks like a bug, will look into it. :)
>>
>> On 16.08.2016 10:29, Ufuk Celebi wrote:
>>
