Hi Robert,
Thanks.
On Sat, Apr 9, 2016 at 12:55 AM, Robert Metzger > wrote:
> Hi,
>
> the runtime context has the following method:
>
> int subtask = getRuntimeContext().getIndexOfThisSubtask();
>
> The RuntimeContext is available in each Rich* function.
>
>
> On Fri, Apr 8, 2016 at 11:46 PM, Dee
Hi,
I also got this error message when I had private inner classes:
public class A {
private class B {
}
}
I was able to fix by making the inner classes public static:
public class A {
public static class B {
}
}
When I was trying to debug it seemed this error message can be ca
Fabian Hueske created FLINK-3738:
Summary: Refactor TableEnvironment and TranslationContext
Key: FLINK-3738
URL: https://issues.apache.org/jira/browse/FLINK-3738
Project: Flink
Issue Type: Ta
Todd Lisonbee created FLINK-3737:
Summary: WikipediaEditsSourceTest.testWikipediaEditsSource() fails
locally
Key: FLINK-3737
URL: https://issues.apache.org/jira/browse/FLINK-3737
Project: Flink
Yijie Shen created FLINK-3736:
-
Summary: Move toRexNode and toAggCall logic into Expressions
Key: FLINK-3736
URL: https://issues.apache.org/jira/browse/FLINK-3736
Project: Flink
Issue Type: Impro
Vasia Kalavri created FLINK-3735:
Summary: Embedded SQL union should fail during translation
Key: FLINK-3735
URL: https://issues.apache.org/jira/browse/FLINK-3735
Project: Flink
Issue Type: B
Ted Yu created FLINK-3734:
-
Summary: Unclosed DataInputView in
AbstractAlignedProcessingTimeWindowOperator#restoreState()
Key: FLINK-3734
URL: https://issues.apache.org/jira/browse/FLINK-3734
Project: Flink
Ted Yu created FLINK-3733:
-
Summary: registeredTypesWithKryoSerializers is not assigned in
ExecutionConfig#deserializeUserCode()
Key: FLINK-3733
URL: https://issues.apache.org/jira/browse/FLINK-3733
Project:
Ted Yu created FLINK-3732:
-
Summary: Potential null deference in ExecutionConfig#equals()
Key: FLINK-3732
URL: https://issues.apache.org/jira/browse/FLINK-3732
Project: Flink
Issue Type: Bug
Vasia Kalavri created FLINK-3731:
Summary: Embedded SQL outer joins should fail during translation
Key: FLINK-3731
URL: https://issues.apache.org/jira/browse/FLINK-3731
Project: Flink
Issue T
I also found an issue in the RocksDB backend (not introduced by me... ;-):
https://issues.apache.org/jira/browse/FLINK-3730
It's not that critical, however.
On Mon, 11 Apr 2016 at 18:40 Till Rohrmann wrote:
> Given that it's low overhead, then +1 for new bug fix release. If we find
> more stuff
Aljoscha Krettek created FLINK-3730:
---
Summary: Fix RocksDB Local Directory Initialization
Key: FLINK-3730
URL: https://issues.apache.org/jira/browse/FLINK-3730
Project: Flink
Issue Type: Bu
Given that it's low overhead, then +1 for new bug fix release. If we find
more stuff later on, then we can release another bug fix version.
Cheers,
Till
On Mon, Apr 11, 2016 at 6:32 PM, Ufuk Celebi wrote:
> Hey all,
>
> we recently released Flink 1.0.1, but some fixes did not make it into
> the
Hey all,
we recently released Flink 1.0.1, but some fixes did not make it into
the release:
Major issues reported by users:
- YARN dynamic properties (to be merged to release-1.0),
- POJO key selection,
- WindowOperator.trigger() and watermarks
Performance improvement:
- Disable WAL in RocksDB
Chesnay Schepler created FLINK-3729:
---
Summary: Several SQL tests fail on Windows OS
Key: FLINK-3729
URL: https://issues.apache.org/jira/browse/FLINK-3729
Project: Flink
Issue Type: Bug
Vasia Kalavri created FLINK-3728:
Summary: Find a way to exclude unsupported SQL features
Key: FLINK-3728
URL: https://issues.apache.org/jira/browse/FLINK-3728
Project: Flink
Issue Type: Bug
Vasia Kalavri created FLINK-3727:
Summary: Add support for embedded streaming SQL (projection,
filter, union)
Key: FLINK-3727
URL: https://issues.apache.org/jira/browse/FLINK-3727
Project: Flink
Maxim Dobryakov created FLINK-3726:
--
Summary: Error while reading configuration: Cannot read property 0
Key: FLINK-3726
URL: https://issues.apache.org/jira/browse/FLINK-3726
Project: Flink
I
Maxim Dobryakov created FLINK-3725:
--
Summary: Exception in thread "main" scala.MatchError: ... (of
class scala.Tuple4)
Key: FLINK-3725
URL: https://issues.apache.org/jira/browse/FLINK-3725
Project: F
Vasia Kalavri created FLINK-3724:
Summary: testJoinPushThroughJoin fails for
TableConfigMode=EFFICIENT
Key: FLINK-3724
URL: https://issues.apache.org/jira/browse/FLINK-3724
Project: Flink
Is
20 matches
Mail list logo
