[jira] [Closed] (FLINK-8685) Code of method "processElement(Ljava/lang/Object;Lorg/apache/flink/streaming/api/functions/ProcessFunction$Context;Lorg/apache/flink/util/Collector;)V" of class "DataStrea

[ https://issues.apache.org/jira/browse/FLINK-8685?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-8685. --- Resolution: Duplicate Fix Version/s: 1.5.0 Thank your for reporting this issue. We

[GitHub] flink issue #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI client

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5441 Thank you @fhueske. I will merge this now and open some follow-up issues. ---

[jira] [Commented] (FLINK-8607) Add a basic embedded SQL CLI client

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

[GitHub] flink pull request #5516: [FLINK-8544] [Kafka Connector] Handle null message...

GitHub user BillLeecn opened a pull request: https://github.com/apache/flink/pull/5516 [FLINK-8544] [Kafka Connector] Handle null message key in JSONKeyValueDeserializationSc… ## What is the purpose of the change This pull request fix a NPE thrown in

[jira] [Commented] (FLINK-8544) JSONKeyValueDeserializationSchema throws NPE when message key is null

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

[jira] [Commented] (FLINK-8667) expose key in KeyedBroadcastProcessFunction#onTimer()

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

[GitHub] flink issue #5501: [FLINK-6053][metrics] Add new Number-/StringGauge metric ...

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5501 Yeah I'm not happy that we now added another instanceof clause. Ultimately we could modify `Counter` and `Meter` to implement `NumberGauge` (returning the count and rate, respectively), but

[GitHub] flink issue #5500: [FLINK-8667] expose key in KeyedBroadcastProcessFunction#...

Github user bowenli86 commented on the issue: https://github.com/apache/flink/pull/5500 @pnowojski @aljoscha I updated the code. Hopefully we can make this into 1.5.0! Thanks! ---

[jira] [Resolved] (FLINK-8607) Add a basic embedded SQL CLI client

[ https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther resolved FLINK-8607. - Resolution: Fixed Fix Version/s: 1.5.0 Fixed in 1.5.0:

[jira] [Commented] (FLINK-8607) Add a basic embedded SQL CLI client

[ https://issues.apache.org/jira/browse/FLINK-8607?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368144#comment-16368144 ] ASF GitHub Bot commented on FLINK-8607: --- Github user asfgit closed the pull request at:

[GitHub] flink issue #5505: [FLINK-8538][table]Add a Kafka table source factory with ...

Github user twalthr commented on the issue: https://github.com/apache/flink/pull/5505 Thanks for the PR @xccui. You are right, we should provide more utility method in `DescriptorProperties`. Especially for improving the interoperability Scala<->Java. I will fix those weaknesses next

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

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

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

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

[jira] [Closed] (FLINK-8612) Add non-detached job mode

[ https://issues.apache.org/jira/browse/FLINK-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8612. Resolution: Fixed Fixed via 0e87e485ba14fc0c8a5f5aa96c79b45ef7fc45d1 > Add non-detached job mode >

[jira] [Resolved] (FLINK-7857) Port JobVertexDetails to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7857?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7857. -- Resolution: Fixed Fixed via  2c027861086ee8be8cc56d6bb424b687ba3f7ffb

[jira] [Closed] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable

[ https://issues.apache.org/jira/browse/FLINK-8662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann closed FLINK-8662. Resolution: Fixed Fixed via 1809e9ff30080f5b65987bcd684d1b5e1056693f >

[GitHub] flink pull request #5209: [FLINK-7711] Port JarListHandler to WebMonitorEndp...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5209 ---

[GitHub] flink pull request #5035: [FLINK-7857][flp6] Port JobVertexDetails to REST e...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5035 ---

[GitHub] flink pull request #5435: [FLINK-8612] [flip6] Enable non-detached job mode

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5435 ---

[GitHub] flink pull request #5455: [FLINK-7711][flip6] Port JarListHandler

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5455 ---

[GitHub] flink pull request #5493: [FLINK-7857][flip6] Port JobVertexDetails to REST ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5493 ---

[GitHub] flink pull request #5494: [FLINK-8662] [tests] Harden FutureUtilsTest#testRe...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5494 ---

[jira] [Commented] (FLINK-7857) Port JobVertexDetails to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368173#comment-16368173 ] ASF GitHub Bot commented on FLINK-7857: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7857) Port JobVertexDetails to REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368174#comment-16368174 ] ASF GitHub Bot commented on FLINK-7857: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-8662) FutureUtilsTest#testRetryWithDelay unstable

[ https://issues.apache.org/jira/browse/FLINK-8662?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368175#comment-16368175 ] ASF GitHub Bot commented on FLINK-8662: --- Github user asfgit closed the pull request at:

[jira] [Resolved] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-7711. -- Resolution: Fixed Fixed via 4e6d22b2135216d1fab97477a6058faf1f84b789 > Port JarListHandler to

[jira] [Commented] (FLINK-8612) Add non-detached job mode

[ https://issues.apache.org/jira/browse/FLINK-8612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368172#comment-16368172 ] ASF GitHub Bot commented on FLINK-8612: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368171#comment-16368171 ] ASF GitHub Bot commented on FLINK-7711: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-7711) Port JarListHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7711?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368170#comment-16368170 ] ASF GitHub Bot commented on FLINK-7711: --- Github user asfgit closed the pull request at:

[jira] [Updated] (FLINK-8274) Fix Java 64K method compiling limitation for CommonCalc

[ https://issues.apache.org/jira/browse/FLINK-8274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler updated FLINK-8274: Affects Version/s: 1.5.0 > Fix Java 64K method compiling limitation for CommonCalc >

[jira] [Created] (FLINK-8686) Improve basic embedded SQL client

Timo Walther created FLINK-8686: --- Summary: Improve basic embedded SQL client Key: FLINK-8686 URL: https://issues.apache.org/jira/browse/FLINK-8686 Project: Flink Issue Type: Improvement

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

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

[GitHub] flink issue #5505: [FLINK-8538][table]Add a Kafka table source factory with ...

Github user xccui commented on the issue: https://github.com/apache/flink/pull/5505 Yes @twalthr, that will be great! I'll start working on the `KafkaAvroTableSourceFactory` and keep an eye on the API refactorings. ---

[GitHub] flink pull request #5441: [FLINK-8607] [table] Add a basic embedded SQL CLI ...

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5441 ---

[jira] [Commented] (FLINK-8073) Test instability FlinkKafkaProducer011ITCase.testScaleDownBeforeFirstCheckpoint()

[ https://issues.apache.org/jira/browse/FLINK-8073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368165#comment-16368165 ] Till Rohrmann commented on FLINK-8073: -- Another instance: 

[GitHub] flink pull request #5509: [FLINK-7715][flip6] Port JarRunHandler to new REST...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5509#discussion_r168929157 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java --- @@ -0,0 +1,229 @@ +/* + *

[GitHub] flink issue #5490: [FLINK-8657][doc]Fix incorrect description in the documen...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5490 @StefanRRichter If that is outdated, could you please merge this PR to fix it? ---

[jira] [Commented] (FLINK-7715) Port JarRunHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368213#comment-16368213 ] ASF GitHub Bot commented on FLINK-7715: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5509: [FLINK-7715][flip6] Port JarRunHandler to new REST...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5509#discussion_r168922506 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java --- @@ -0,0 +1,229 @@ +/* + *

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

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

[GitHub] flink issue #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBackend.getKe...

Github user sihuazhou commented on the issue: https://github.com/apache/flink/pull/5518 @pnowojski Could you please have a look at this? ---

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168923464 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -336,1697

[jira] [Commented] (FLINK-7477) Use "hadoop classpath" to augment classpath when available

[ https://issues.apache.org/jira/browse/FLINK-7477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368202#comment-16368202 ] Aljoscha Krettek commented on FLINK-7477: - [~kkrugler] So on YARN, the current setup works for you

[jira] [Commented] (FLINK-5886) Python API for streaming applications

[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368278#comment-16368278 ] ASF GitHub Bot commented on FLINK-5886: --- Github user asfgit closed the pull request at:

[jira] [Commented] (FLINK-5886) Python API for streaming applications

[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368277#comment-16368277 ] ASF GitHub Bot commented on FLINK-5886: --- Github user asfgit closed the pull request at:

[GitHub] flink pull request #5333: [FLINK-5886] Python API for streaming applications

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5333 ---

[jira] [Created] (FLINK-8687) MaterializedCollectStreamResult#retrievePage should take resultLock

Ted Yu created FLINK-8687: - Summary: MaterializedCollectStreamResult#retrievePage should take resultLock Key: FLINK-8687 URL: https://issues.apache.org/jira/browse/FLINK-8687 Project: Flink Issue

[jira] [Commented] (FLINK-8657) Fix incorrect description for external checkpoint vs savepoint

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

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168923188 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -336,1697

[jira] [Closed] (FLINK-5886) Python API for streaming applications

[ https://issues.apache.org/jira/browse/FLINK-5886?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-5886. --- Resolution: Fixed Fix Version/s: 1.5.0 master:

[GitHub] flink pull request #3838: [FLINK-5886] Python API for streaming applications

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/3838 ---

[jira] [Commented] (FLINK-8678) Make AkkaRpcService#stopService non-blocking

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

[GitHub] flink pull request #5517: [FLINK-8678] [flip6] Make RpcService shut down non...

GitHub user tillrohrmann opened a pull request: https://github.com/apache/flink/pull/5517 [FLINK-8678] [flip6] Make RpcService shut down non blocking ## What is the purpose of the change Changes the RpcService#stopService method to be non blocking. Instead of waiting

[jira] [Updated] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

[ https://issues.apache.org/jira/browse/FLINK-8679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sihua Zhou updated FLINK-8679: -- Priority: Critical (was: Major) > RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter

[jira] [Commented] (FLINK-8679) RocksDBKeyedBackend.getKeys(stateName, namespace) doesn't filter data with namespace

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

[GitHub] flink pull request #5518: [FLINK-8679][State Backends]Fix RocksDBKeyedBacken...

GitHub user sihuazhou opened a pull request: https://github.com/apache/flink/pull/5518 [FLINK-8679][State Backends]Fix RocksDBKeyedBackend.getKeys() bug for missing namespace condition. This PR addressed issue [FLINK-8679](https://issues.apache.org/jira/browse/FLINK-8679).

[GitHub] flink pull request #5239: [FLINK-8360] Implement task-local state recovery

Github user sihuazhou commented on a diff in the pull request: https://github.com/apache/flink/pull/5239#discussion_r168923652 --- Diff: flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java --- @@ -336,1697

[jira] [Commented] (FLINK-5886) Python API for streaming applications

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

[jira] [Commented] (FLINK-7715) Port JarRunHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368310#comment-16368310 ] ASF GitHub Bot commented on FLINK-7715: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5509: [FLINK-7715][flip6] Port JarRunHandler to new REST...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5509#discussion_r168922479 --- Diff: flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java --- @@ -1126,7 +1126,7 @@ public static void

[jira] [Commented] (FLINK-7715) Port JarRunHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368212#comment-16368212 ] ASF GitHub Bot commented on FLINK-7715: --- Github user tillrohrmann commented on a diff in the pull

[jira] [Commented] (FLINK-8599) Improve the failure behavior of the ContinuousFileReaderOperator for bad files

[ https://issues.apache.org/jira/browse/FLINK-8599?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368348#comment-16368348 ] ASF GitHub Bot commented on FLINK-8599: --- Github user ChengzhiZhao closed the pull request at:

[GitHub] flink pull request #5514: [FLINK-8599] Improve the failure behavior of the C...

Github user ChengzhiZhao closed the pull request at: https://github.com/apache/flink/pull/5514 ---

[jira] [Commented] (FLINK-7715) Port JarRunHandler to new REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-7715?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368326#comment-16368326 ] ASF GitHub Bot commented on FLINK-7715: --- Github user tillrohrmann commented on a diff in the pull

[GitHub] flink pull request #5509: [FLINK-7715][flip6] Port JarRunHandler to new REST...

Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5509#discussion_r168930002 --- Diff: flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/handlers/JarRunHandler.java --- @@ -0,0 +1,229 @@ +/* + *

[GitHub] flink issue #5333: [FLINK-5886] Python API for streaming applications

Github user zentol commented on the issue: https://github.com/apache/flink/pull/5333 merging. ---

[jira] [Commented] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS

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

[jira] [Commented] (FLINK-8684) Rework MesosTaskManagerParameters#MESOS_RM_TASKS_SLOTS

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

[GitHub] flink issue #5519: [FLINK-8684] [config] Rework MesosTaskManagerParameters#M...

Github user zhangminglei commented on the issue: https://github.com/apache/flink/pull/5519 I'm not very sure whether this PR is necessarily needed, as this already seems to be fixed at FLINK-8683 ---

[GitHub] flink pull request #5519: [FLINK-8684] [config] Rework MesosTaskManagerParam...

GitHub user zhangminglei opened a pull request: https://github.com/apache/flink/pull/5519 [FLINK-8684] [config] Rework MesosTaskManagerParameters#MESOS_RM_TASK… ## What is the purpose of the change Directly by using ```TaskManagerOptions.NUM_TASK_SLOTS``` as it's alias to