[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165587359 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java --- @@

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165588489 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165589748 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165591410 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -192,6

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165587909 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165588295 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165588395 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165589453 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165586434 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java --- @@

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165586994 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/KinesisDataFetcher.java --- @@

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165588081 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisShardAssigner.java --- @@ -0,0

[GitHub] flink pull request #5393: [FLINK-8516] Allow for custom hash function for sh...

Github user tzulitai commented on a diff in the pull request: https://github.com/apache/flink/pull/5393#discussion_r165594279 --- Diff: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisConsumer.java --- @@ -192,6

[jira] [Created] (FLINK-8550) Iterate over entryset instead of keys

Hequn Cheng created FLINK-8550: -- Summary: Iterate over entryset instead of keys Key: FLINK-8550 URL: https://issues.apache.org/jira/browse/FLINK-8550 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions

[ https://issues.apache.org/jira/browse/FLINK-8549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349989#comment-16349989 ] ASF GitHub Bot commented on FLINK-8549: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request #5402: [FLINK-8549] [config] Move TimerServiceOptions int...

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/5402 [FLINK-8549] [config] Move TimerServiceOptions into TaskManagerOptions The `TimerServiceOptions` are in the wrong place, which prohibits generation of config docs. It also cause

[jira] [Created] (FLINK-8549) Move TimerServiceOptions to TaskManagerOptions

Stephan Ewen created FLINK-8549: --- Summary: Move TimerServiceOptions to TaskManagerOptions Key: FLINK-8549 URL: https://issues.apache.org/jira/browse/FLINK-8549 Project: Flink Issue Type:

[jira] [Commented] (FLINK-8545) Implement upsert stream table source

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349962#comment-16349962 ] Fabian Hueske commented on FLINK-8545: -- Yes, you are right. We also need to support a deletion flag.

[jira] [Commented] (FLINK-8357) enable rolling in default log settings

[ https://issues.apache.org/jira/browse/FLINK-8357?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349948#comment-16349948 ] ASF GitHub Bot commented on FLINK-8357: --- Github user StephanEwen commented on the issue:

[GitHub] flink issue #5371: [FLINK-8357] [conf] Enable rolling in default log setting...

Github user StephanEwen commented on the issue: https://github.com/apache/flink/pull/5371 The CI Server reports the following problem below. Apparently the configurations cause warnings to be printed. Can you have a look at that? ``` Found non-empty .out files:

[jira] [Commented] (FLINK-8548) Add Streaming State Machine Example

[ https://issues.apache.org/jira/browse/FLINK-8548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16349946#comment-16349946 ] ASF GitHub Bot commented on FLINK-8548: --- GitHub user StephanEwen opened a pull request:

[GitHub] flink pull request #5401: [FLINK-8548] [examples] Add state machine example

GitHub user StephanEwen opened a pull request: https://github.com/apache/flink/pull/5401 [FLINK-8548] [examples] Add state machine example Example: Running a state machine for pattern detection == This example

[jira] [Created] (FLINK-8548) Add Streaming State Machine Example

Stephan Ewen created FLINK-8548: --- Summary: Add Streaming State Machine Example Key: FLINK-8548 URL: https://issues.apache.org/jira/browse/FLINK-8548 Project: Flink Issue Type: Sub-task

<    1   2