Shuyi Chen created FLINK-9477:
-
Summary: Support SQL 2016 JSON functions in Flink SQL
Key: FLINK-9477
URL: https://issues.apache.org/jira/browse/FLINK-9477
Project: Flink
Issue Type: New Feature
aitozi created FLINK-9476:
-
Summary: Lost sideOutPut Late Elements in CEP Operator
Key: FLINK-9476
URL: https://issues.apache.org/jira/browse/FLINK-9476
Project: Flink
Issue Type: Improvement
Sihua Zhou created FLINK-9475:
-
Summary: introduce an approximate version of "select distinct"
Key: FLINK-9475
URL: https://issues.apache.org/jira/browse/FLINK-9475
Project: Flink
Issue Type: New
Hi,
I did a survey of the variants of Bloom Filter and the Cuckoo filter these
days. Finally, I found 3 of them maybe adaptable for our purpose.
1. standard bloom filter (which we have implemented base on this and used it on
production with a good experience)
2. cuckoo filter, also a very goo
Sihua Zhou created FLINK-9474:
-
Summary: Introduce an approximate version of "count distinct"
Key: FLINK-9474
URL: https://issues.apache.org/jira/browse/FLINK-9474
Project: Flink
Issue Type: New
Sergey Nuyanzin created FLINK-9473:
--
Summary: Compilation fails after upgrade to Calcite 1.17
Key: FLINK-9473
URL: https://issues.apache.org/jira/browse/FLINK-9473
Project: Flink
Issue Type:
+1. you can also run `mvn clean verify` locally before a PR, or `mvn verify
-o` against the module you modified (this will speed up the build)
On Tue, May 29, 2018 at 5:34 AM, Chesnay Schepler
wrote:
> There are some tests that are unstable. Committers will evaluate whether
> the failure is rela
Alexey Tsitkin created FLINK-9472:
-
Summary: Maven archetype code has typo in documentation
Key: FLINK-9472
URL: https://issues.apache.org/jira/browse/FLINK-9472
Project: Flink
Issue Type: Bu
SUBRAMANYA SURESH created FLINK-9471:
Summary: Job ending exceptions being logged at Info level
Key: FLINK-9471
URL: https://issues.apache.org/jira/browse/FLINK-9471
Project: Flink
Issue
Time zone is a very useful feature, I think there are three levels of time
zone settings (priority from high to low):
1. connectors: For example, the time zone of the time field in the kafaka
data
2. job level: Specifies which time zone the current job uses, perhaps
specified by TableConfig or Stre
Aljoscha Krettek created FLINK-9470:
---
Summary: Allow querying the key in KeyedProcessFunction
Key: FLINK-9470
URL: https://issues.apache.org/jira/browse/FLINK-9470
Project: Flink
Issue Type
Dawid Wysakowicz created FLINK-9469:
---
Summary: Add tests that cover PatternStream#flatSelect
Key: FLINK-9469
URL: https://issues.apache.org/jira/browse/FLINK-9469
Project: Flink
Issue Type:
Sihua Zhou created FLINK-9468:
-
Summary: get outputLimit of LimitedConnectionsFileSystem
incorrectly
Key: FLINK-9468
URL: https://issues.apache.org/jira/browse/FLINK-9468
Project: Flink
Issue Ty
There are some tests that are unstable. Committers will evaluate whether
the failure is related to the PR.
Please do not push commits for the sake of getting that perfect green build.
In your particular case you've added files that do not have an apache
license header:
17:43:48.333 [ERROR] Fa
Hi,
The interesting line is:
17:43:48.333 [ERROR] Failed to execute goal
org.apache.rat:apache-rat-plugin:0.12:check (default) on project flink-parent:
Too many files with unapproved license: 1 See RAT report in:
/home/travis/build/Jicaar/flink/target/rat.txt -> [Help 1]
It basically means th
I am new to committing code to a git repo, so I apologize if I ask anything
really obvious.
So I have submitted a pull request for Flink and the TravisIO tests all pass
except ones where TEST=“misc”. Looking through the output of the tests I can’t
figure out what is wrong. There were tests tha
Truong Duc Kien created FLINK-9467:
--
Summary: No Watermark display on Web UI
Key: FLINK-9467
URL: https://issues.apache.org/jira/browse/FLINK-9467
Project: Flink
Issue Type: Bug
Affects
Till Rohrmann created FLINK-9466:
Summary: LocalRecoveryRocksDBFullITCase failed on Travis
Key: FLINK-9466
URL: https://issues.apache.org/jira/browse/FLINK-9466
Project: Flink
Issue Type: Bug
I see Shuyi's point that it would nice to allow adding jar files which
should be part of the user code classloader programmatically. Actually, we
expose this functionality in the `RemoteEnvironment` where you can specify
additional jars which shall be shipped to the cluster in the constructor. I
as
+1
> On 29. May 2018, at 09:34, Till Rohrmann wrote:
>
> Thanks for the great design document Stefan. Unifying how Flink handles
> state such that all checkpointable state is maintained by the StateBackend
> makes a lot of sense to me. Also making the timer service scalable and
> adding support
Truong Duc Kien created FLINK-9465:
--
Summary: Separate timeout for savepoint and checkpoint
Key: FLINK-9465
URL: https://issues.apache.org/jira/browse/FLINK-9465
Project: Flink
Issue Type: I
Till Rohrmann created FLINK-9464:
Summary: Clean up pom files
Key: FLINK-9464
URL: https://issues.apache.org/jira/browse/FLINK-9464
Project: Flink
Issue Type: Improvement
Components
Piotr Nowojski created FLINK-9463:
-
Summary: Setting taskmanager.network.netty.transport to epoll
Key: FLINK-9463
URL: https://issues.apache.org/jira/browse/FLINK-9463
Project: Flink
Issue T
Till Rohrmann created FLINK-9462:
Summary: Disentangle flink-json and flink-table
Key: FLINK-9462
URL: https://issues.apache.org/jira/browse/FLINK-9462
Project: Flink
Issue Type: Improvement
Till Rohrmann created FLINK-9461:
Summary: Disentangle flink-connector-kafka from flink-table and
flink-json
Key: FLINK-9461
URL: https://issues.apache.org/jira/browse/FLINK-9461
Project: Flink
Thanks for the great design document Stefan. Unifying how Flink handles
state such that all checkpointable state is maintained by the StateBackend
makes a lot of sense to me. Also making the timer service scalable and
adding support for asynchronous checkpoints is really important for many
Flink us
26 matches
Mail list logo
