[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

2018-02-14 Thread bowenli86
Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5481 cc @pnowojski ---

[jira] [Updated] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8560: Summary: Access to the current key in ProcessFunction#OnTimerContext after keyBy() (was: Access to the curr

[jira] [Updated] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8560: Affects Version/s: 1.4.0 > Access to the current key in ProcessFunction#OnTimerContext after keyBy() > -

[jira] [Updated] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8560: Fix Version/s: 1.5.0 > Access to the current key in ProcessFunction#OnTimerContext after keyBy() > -

[jira] [Updated] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8560: Priority: Major (was: Minor) > Access to the current key in ProcessFunction#OnTimerContext after keyBy() >

[jira] [Updated] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-8560: Issue Type: Improvement (was: Wish) > Access to the current key in ProcessFunction#OnTimerContext after key

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363630#comment-16363630 ] ASF GitHub Bot commented on FLINK-8560: --- Github user bowenli86 commented on the issu

[GitHub] flink issue #5479: [FLINK-8649] [scala api] Pass on TypeInfo in StreamExecut...

2018-02-14 Thread twalthr
Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5479 Thank you @ggevay. I will look at this soon. ---

[jira] [Commented] (FLINK-8649) Scala StreamExecutionEnvironment.createInput should pass on the TypeInfo

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363644#comment-16363644 ] ASF GitHub Bot commented on FLINK-8649: --- Github user twalthr commented on the issue:

[jira] [Created] (FLINK-8651) Add support for different event-time OVER windows in a query

2018-02-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8651: Summary: Add support for different event-time OVER windows in a query Key: FLINK-8651 URL: https://issues.apache.org/jira/browse/FLINK-8651 Project: Flink I

[jira] [Closed] (FLINK-6250) Distinct procTime with Rows boundaries

2018-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6250. Resolution: Duplicate Closed as duplicate of FLINK-6249 > Distinct procTime with Rows boundaries >

[jira] [Closed] (FLINK-6252) Distinct rowTime with Rows boundaries

2018-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6252. Resolution: Duplicate Closed as duplicate of FLINK-6249 > Distinct rowTime with Rows boundaries > -

[jira] [Closed] (FLINK-6253) Distinct rowTime with time range boundaries

2018-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6253. Resolution: Duplicate Closed as duplicate of FLINK-6249 > Distinct rowTime with time range boundari

[jira] [Closed] (FLINK-6251) Distinct procTime with time range boundaries

2018-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske closed FLINK-6251. Resolution: Duplicate Closed as duplicate of FLINK-6249 > Distinct procTime with time range boundar

[jira] [Commented] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices

2018-02-14 Thread mingleizhang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363685#comment-16363685 ] mingleizhang commented on FLINK-8212: - Thanks [~till.rohrmann] I will correct the code

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: jobmanager.log > RocksDB state backend Checkpointing (Async and Incremental) is not wor

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: taskmanager.log > RocksDB state backend Checkpointing (Async and Incremental) is not wo

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: (was: taskmanager.log) > RocksDB state backend Checkpointing (Async and Incremental)

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: (was: jobmanager.log) > RocksDB state backend Checkpointing (Async and Incremental)

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: taskmanager_without_cassandra.log > RocksDB state backend Checkpointing (Async and Incre

[jira] [Updated] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] tarun razdan updated FLINK-7756: Attachment: jobmanager_without_cassandra.log > RocksDB state backend Checkpointing (Async and Increm

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread tarun razdan (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363694#comment-16363694 ] tarun razdan commented on FLINK-7756: - Hi [~aljoscha] , I'm Tarun from [~shashank734]

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363700#comment-16363700 ] Xingcan Cui commented on FLINK-8538: BTW, it may not be a good idea to implement them

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

2018-02-14 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r168121129 --- Diff: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/KeyedProcessOperatorTest.java --- @@ -397,17 +396,16 @@ public void

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363703#comment-16363703 ] ASF GitHub Bot commented on FLINK-8560: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #5481: [FLINK-8560] Access to the current key in ProcessF...

2018-02-14 Thread pnowojski
Github user pnowojski commented on a diff in the pull request: https://github.com/apache/flink/pull/5481#discussion_r168122242 --- Diff: flink-libraries/flink-table/src/main/scala/org/apache/flink/table/runtime/aggregate/GroupAggProcessFunction.scala --- @@ -162,7 +162,7 @@ class

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363704#comment-16363704 ] ASF GitHub Bot commented on FLINK-8560: --- Github user pnowojski commented on a diff i

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r168126480 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/entrypoint/ClusterEntrypoint.java --- @@ -163,29 +210,130 @@ protected void runCluster(Configurat

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363722#comment-16363722 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363724#comment-16363724 ] Timo Walther commented on FLINK-8538: - [~xccui] good point maybe we should make those

[jira] [Comment Edited] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-14 Thread Timo Walther (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363724#comment-16363724 ] Timo Walther edited comment on FLINK-8538 at 2/14/18 10:05 AM: -

[GitHub] flink pull request #5482: [Flink-8480][DataStream] Add Java API for timeboun...

2018-02-14 Thread florianschmidt1994
GitHub user florianschmidt1994 opened a pull request: https://github.com/apache/flink/pull/5482 [Flink-8480][DataStream] Add Java API for timebounded stream join ## What is the purpose of the change * Add a JavaAPI to the DataStream API to join two streams based on user-def

[jira] [Commented] (FLINK-8479) Implement time-bounded inner join of streams as a TwoInputStreamOperator

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8479?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363732#comment-16363732 ] ASF GitHub Bot commented on FLINK-8479: --- GitHub user florianschmidt1994 opened a pul

[jira] [Commented] (FLINK-8574) Add timestamps to travis logging messages

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363736#comment-16363736 ] ASF GitHub Bot commented on FLINK-8574: --- Github user zentol commented on the issue:

[GitHub] flink issue #5419: [FLINK-8574][travis] Add timestamp to logging messages

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5419 Looks like that isn't possible. As far as i can tell surefire does not use slfj4 but the plexus ConsoleLogger, and it looks like that one does not support timestamps. ---

[GitHub] flink pull request #5431: [FLINK-8608] [flip6] Implement MiniDispatcher for ...

2018-02-14 Thread GJL
Github user GJL commented on a diff in the pull request: https://github.com/apache/flink/pull/5431#discussion_r168132269 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/MiniDispatcherTest.java --- @@ -0,0 +1,208 @@ +/* + * Licensed to the Apache S

[jira] [Commented] (FLINK-8608) Add MiniDispatcher for job mode

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363745#comment-16363745 ] ASF GitHub Bot commented on FLINK-8608: --- Github user GJL commented on a diff in the

[jira] [Commented] (FLINK-8628) BucketingSink does not work with S3

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8628?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363759#comment-16363759 ] Aljoscha Krettek commented on FLINK-8628: - Also, this issue is probably fixed in 1

[GitHub] flink issue #5420: [FLINK-8576][QS] Reduce verbosity when classes can't be f...

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5420 @kl0u Thanks for the pointer, have updated the PR accordingly. ---

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363761#comment-16363761 ] ASF GitHub Bot commented on FLINK-8576: --- Github user zentol commented on the issue:

[GitHub] flink issue #5427: [FLINK-8533] [checkpointing] Support MasterTriggerRestore...

2018-02-14 Thread tillrohrmann
Github user tillrohrmann commented on the issue: https://github.com/apache/flink/pull/5427 @EronWright, you're right that on initial submission we don't call `restoreLatestCheckpointedState` in the old code. With Flip-6 this will be the case. See #5444. The underlying assumpt

[jira] [Commented] (FLINK-8533) Support MasterTriggerRestoreHook state reinitialization

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8533?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363764#comment-16363764 ] ASF GitHub Bot commented on FLINK-8533: --- Github user tillrohrmann commented on the i

[GitHub] flink pull request #5420: [FLINK-8576][QS] Reduce verbosity when classes can...

2018-02-14 Thread kl0u
Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/5420#discussion_r168137274 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateUtils.java --- @@ -132,9 +134,7 @@ public static KvStateServer createKvState

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363766#comment-16363766 ] ASF GitHub Bot commented on FLINK-8576: --- Github user kl0u commented on a diff in the

[GitHub] flink issue #5459: [FLINK-8475][config][docs] Integrate FS options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5459 merging ---

[GitHub] flink issue #5470: [FLINK-8475][config][docs] Integrate RM options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5470 merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363776#comment-16363776 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363774#comment-16363774 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5467: [FLINK-8475][config][docs] Integrate HA options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5467 merging ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363772#comment-16363772 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5468: [FLINK-8475][config][docs] Integrate Environment options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5468 merging ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363775#comment-16363775 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[GitHub] flink issue #5471: [FLINK-8475][config][docs] Integrate TM options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5471 merging. ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363777#comment-16363777 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Created] (FLINK-8652) Reduce log level of QueryableStateClient.getKvState() to DEBUG

2018-02-14 Thread Fabian Hueske (JIRA)
Fabian Hueske created FLINK-8652: Summary: Reduce log level of QueryableStateClient.getKvState() to DEBUG Key: FLINK-8652 URL: https://issues.apache.org/jira/browse/FLINK-8652 Project: Flink

[GitHub] flink issue #5481: [FLINK-8560] Access to the current key in ProcessFunction...

2018-02-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5481 @bowenli86 You can take a look at `KeyedBroadcastProcessFunction`. I think we could also add a `KeyedProcessFunction`, that has the key type in the signature. This would allow exposing the key in `o

[GitHub] flink pull request #5420: [FLINK-8576][QS] Reduce verbosity when classes can...

2018-02-14 Thread zentol
Github user zentol commented on a diff in the pull request: https://github.com/apache/flink/pull/5420#discussion_r168138976 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/query/QueryableStateUtils.java --- @@ -132,9 +134,7 @@ public static KvStateServer createKvSta

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363782#comment-16363782 ] ASF GitHub Bot commented on FLINK-8576: --- Github user zentol commented on a diff in t

[jira] [Commented] (FLINK-8560) Access to the current key in ProcessFunction#OnTimerContext after keyBy()

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363781#comment-16363781 ] ASF GitHub Bot commented on FLINK-8560: --- Github user aljoscha commented on the issue

[jira] [Commented] (FLINK-8652) Reduce log level of QueryableStateClient.getKvState() to DEBUG

2018-02-14 Thread Kostas Kloudas (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363784#comment-16363784 ] Kostas Kloudas commented on FLINK-8652: --- [~fhueske] I agree! > Reduce log level of

[jira] [Assigned] (FLINK-8652) Reduce log level of QueryableStateClient.getKvState() to DEBUG

2018-02-14 Thread Fabian Hueske (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Fabian Hueske reassigned FLINK-8652: Assignee: Fabian Hueske > Reduce log level of QueryableStateClient.getKvState() to DEBUG >

[GitHub] flink issue #5420: [FLINK-8576][QS] Reduce verbosity when classes can't be f...

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5420 merging ---

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363797#comment-16363797 ] ASF GitHub Bot commented on FLINK-8576: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-8411) HeapListState#add(null) will wipe out entire list state

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363798#comment-16363798 ] Aljoscha Krettek commented on FLINK-8411: - [~phoenixjiangnan] I agree, I will chan

[jira] [Commented] (FLINK-8538) Add a Kafka table source factory with JSON format support

2018-02-14 Thread Xingcan Cui (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363802#comment-16363802 ] Xingcan Cui commented on FLINK-8538: Hi [~twalthr], I think Friday will be fine. Thoug

[jira] [Updated] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8576: Fix Version/s: 1.4.2 > Log message for QueryableState loading failure too verbose >

[jira] [Updated] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8576: Affects Version/s: 1.4.0 > Log message for QueryableState loading failure too verbose >

[jira] [Updated] (FLINK-7343) Kafka010ProducerITCase instability

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7343: Priority: Blocker (was: Major) > Kafka010ProducerITCase instability > -

[jira] [Updated] (FLINK-7343) Kafka010ProducerITCase instability

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aljoscha Krettek updated FLINK-7343: Fix Version/s: (was: 1.4.0) 1.5.0 > Kafka010ProducerITCase instabilit

[GitHub] flink issue #5469: [FLINK-8475][config][docs] Integrate Core options

2018-02-14 Thread aljoscha
Github user aljoscha commented on the issue: https://github.com/apache/flink/pull/5469 Ok, sounds fine to me then. 👍 ---

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363814#comment-16363814 ] ASF GitHub Bot commented on FLINK-8475: --- Github user aljoscha commented on the issue

[GitHub] flink issue #5469: [FLINK-8475][config][docs] Integrate Core options

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5469 merging. ---

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363819#comment-16363819 ] Aljoscha Krettek commented on FLINK-7756: - There is only one TaskManager, correct?

[jira] [Commented] (FLINK-8475) Move remaining sections to generated tables

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8475?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363818#comment-16363818 ] ASF GitHub Bot commented on FLINK-8475: --- Github user zentol commented on the issue:

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363823#comment-16363823 ] Aljoscha Krettek commented on FLINK-7756: - Could you also do a quick listing of th

[jira] [Updated] (FLINK-5779) Auto generate configuration docs

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5779: Component/s: Configuration > Auto generate configuration docs >

[jira] [Updated] (FLINK-5779) Auto generate configuration docs

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-5779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-5779: Fix Version/s: 1.5.0 > Auto generate configuration docs > >

[jira] [Commented] (FLINK-7756) RocksDB state backend Checkpointing (Async and Incremental) is not working with CEP.

2018-02-14 Thread Aljoscha Krettek (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7756?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363826#comment-16363826 ] Aljoscha Krettek commented on FLINK-7756: - Also, did you ever try running this wit

[GitHub] flink issue #5418: [FLINK-8553] switch flink-metrics-datadog to async mode

2018-02-14 Thread zentol
Github user zentol commented on the issue: https://github.com/apache/flink/pull/5418 merging. ---

[jira] [Commented] (FLINK-8553) switch flink-metrics-datadog to async mode

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363832#comment-16363832 ] ASF GitHub Bot commented on FLINK-8553: --- Github user zentol commented on the issue:

[jira] [Updated] (FLINK-7286) Flink Dashboard fails to display bytes/records received by sources

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-7286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-7286: Component/s: Metrics > Flink Dashboard fails to display bytes/records received by sources >

[jira] [Created] (FLINK-8653) Remove slot request timeout from SlotPool

2018-02-14 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-8653: Summary: Remove slot request timeout from SlotPool Key: FLINK-8653 URL: https://issues.apache.org/jira/browse/FLINK-8653 Project: Flink Issue Type: Improveme

[jira] [Commented] (FLINK-8653) Remove slot request timeout from SlotPool

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8653?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363838#comment-16363838 ] ASF GitHub Bot commented on FLINK-8653: --- GitHub user tillrohrmann opened a pull requ

[GitHub] flink pull request #5483: [FLINK-8653] [flip6] Remove internal slot request ...

2018-02-14 Thread tillrohrmann
GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5483 [FLINK-8653] [flip6] Remove internal slot request timeout from SlotPool ## What is the purpose of the change Instead of using the internal slot request timeout to time out pending slot

[GitHub] flink pull request #5484: [FLINK-8593][metrics] Update latency metric docs

2018-02-14 Thread zentol
GitHub user zentol opened a pull request: https://github.com/apache/flink/pull/5484 [FLINK-8593][metrics] Update latency metric docs This PR updates the documentation of the latency metric to be in line with the recent changes in [FLINK-7608](https://issues.apache.org/jira/browse/F

[jira] [Commented] (FLINK-8593) Latency metric docs are outdated

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363846#comment-16363846 ] ASF GitHub Bot commented on FLINK-8593: --- GitHub user zentol opened a pull request:

[jira] [Assigned] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-6053: --- Assignee: Chesnay Schepler > Gauge should only take subclasses of Number, rather than

[jira] [Updated] (FLINK-6053) Gauge should only take subclasses of Number, rather than everything

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-6053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-6053: Fix Version/s: (was: 2.0.0) 1.5.0 > Gauge should only take subclasses

[jira] [Created] (FLINK-8654) Extend quickstart docs on how to submit jobs

2018-02-14 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-8654: --- Summary: Extend quickstart docs on how to submit jobs Key: FLINK-8654 URL: https://issues.apache.org/jira/browse/FLINK-8654 Project: Flink Issue Type:

[GitHub] flink issue #5458: [FLINK-8212] [network] Pull EnvironmentInformation out of...

2018-02-14 Thread zhangminglei
Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5458 @tillrohrmann I updated the code. Could you take a look ? Thanks ~ ---

[jira] [Commented] (FLINK-8212) Pull EnvironmentInformation out of TaskManagerServices

2018-02-14 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363878#comment-16363878 ] ASF GitHub Bot commented on FLINK-8212: --- Github user zhangminglei commented on the i

[GitHub] flink pull request #5470: [FLINK-8475][config][docs] Integrate RM options

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5470 ---

[jira] [Commented] (FLINK-8576) Log message for QueryableState loading failure too verbose

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16363893#comment-16363893 ] Chesnay Schepler commented on FLINK-8576: - master: e7f4f53c131d919db1073adedbfa487

[GitHub] flink pull request #5418: [FLINK-8553] switch flink-metrics-datadog to async...

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5418 ---

[GitHub] flink pull request #5468: [FLINK-8475][config][docs] Integrate Environment o...

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5468 ---

[GitHub] flink pull request #5469: [FLINK-8475][config][docs] Integrate Core options

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5469 ---

[GitHub] flink pull request #5420: [FLINK-8576][QS] Reduce verbosity when classes can...

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5420 ---

[jira] [Closed] (FLINK-8553) switch flink-metrics-datadog to async mode

2018-02-14 Thread Chesnay Schepler (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-8553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8553. --- Resolution: Fixed master: ae3d547afe7ec44d37b38222a3ea40d9181e > switch flink-metrics-dat

[GitHub] flink pull request #5467: [FLINK-8475][config][docs] Integrate HA options

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5467 ---

[GitHub] flink pull request #5471: [FLINK-8475][config][docs] Integrate TM options

2018-02-14 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5471 ---

  1   2   3   4   5   >