aljoscha |
[GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc... |
Tue, 02 Jan, 13:18 |
aljoscha |
[GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc... |
Tue, 02 Jan, 13:18 |
aljoscha |
[GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc... |
Tue, 02 Jan, 13:18 |
aljoscha |
[GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc... |
Tue, 02 Jan, 13:18 |
aljoscha |
[GitHub] flink pull request #5230: [FLINK-8345] Add iterator of keyed state on broadc... |
Tue, 02 Jan, 13:18 |
Till Rohrmann (JIRA) |
[jira] [Created] (FLINK-8347) Make Cluster id typesafe |
Tue, 02 Jan, 13:48 |
tillrohrmann |
[GitHub] flink pull request #5232: [FLINK-8347] [flip6] Make cluster id used by Clust... |
Tue, 02 Jan, 13:51 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8347) Make Cluster id typesafe |
Tue, 02 Jan, 13:52 |
NicoK |
[GitHub] flink issue #5176: [FLINK-8279][blob] fall back to TaskManager temp director... |
Tue, 02 Jan, 13:54 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories |
Tue, 02 Jan, 13:55 |
aljoscha |
[GitHub] flink issue #5185: [FLINK-8297] [flink-rocksdb] optionally use RocksDBMapSta... |
Tue, 02 Jan, 13:55 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8297) RocksDBListState stores whole list in single byte[] |
Tue, 02 Jan, 13:56 |
Till Rohrmann (JIRA) |
[jira] [Assigned] (FLINK-8343) Add support for job cluster deployment |
Tue, 02 Jan, 14:12 |
Till Rohrmann (JIRA) |
[jira] [Created] (FLINK-8348) Print help for DefaultCLI |
Tue, 02 Jan, 14:13 |
Aljoscha Krettek (JIRA) |
[jira] [Updated] (FLINK-8257) Unify the value checks for setParallelism() |
Tue, 02 Jan, 14:22 |
aljoscha |
[GitHub] flink issue #5192: [FLINK-8257] [conf] Unify the value checks for setParalle... |
Tue, 02 Jan, 14:22 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8257) Unify the value checks for setParallelism() |
Tue, 02 Jan, 14:23 |
Aljoscha Krettek (JIRA) |
[jira] [Closed] (FLINK-8257) Unify the value checks for setParallelism() |
Tue, 02 Jan, 14:23 |
tillrohrmann |
[GitHub] flink pull request #5233: [FLINK-8348] [flip6] Print help for DefaultCLI |
Tue, 02 Jan, 14:27 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8348) Print help for DefaultCLI |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
GJL |
[GitHub] flink pull request #5215: [FLINK-8328] [flip6] Move Yarn ApplicationStatus p... |
Tue, 02 Jan, 14:28 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
Till Rohrmann (JIRA) |
[jira] [Updated] (FLINK-8119) Cannot submit jobs to YARN Session in FLIP-6 mode |
Tue, 02 Jan, 14:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8328) Pull Yarn ApplicationStatus polling out of YarnClusterClient |
Tue, 02 Jan, 14:29 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:33 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:34 |
tillrohrmann |
[GitHub] flink pull request #5234: [FLINK-8119] [flip6] Wire correct Flip6 components... |
Tue, 02 Jan, 14:39 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8119) Cannot submit jobs to YARN Session in FLIP-6 mode |
Tue, 02 Jan, 14:40 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8268) Test instability for 'TwoPhaseCommitSinkFunctionTest' |
Tue, 02 Jan, 14:43 |
pnowojski |
[GitHub] flink pull request #5193: [FLINK-8268][tests] Improve tests stability |
Tue, 02 Jan, 14:43 |
Till Rohrmann (JIRA) |
[jira] [Created] (FLINK-8349) Remove Yarn specific commands from YarnClusterClient |
Tue, 02 Jan, 14:46 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer |
Tue, 02 Jan, 14:56 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8327) ClassLoader resolution of child-first does not appear to work |
Tue, 02 Jan, 15:07 |
GJL |
[GitHub] flink pull request #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYa... |
Tue, 02 Jan, 15:13 |
GJL |
[GitHub] flink pull request #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYa... |
Tue, 02 Jan, 15:13 |
GJL |
[GitHub] flink pull request #5216: [FLINK-8329] [flip6] Move YarnClient to AbstractYa... |
Tue, 02 Jan, 15:13 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8329) Move YarnClient out of YarnClusterClient |
Tue, 02 Jan, 15:14 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8329) Move YarnClient out of YarnClusterClient |
Tue, 02 Jan, 15:14 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8329) Move YarnClient out of YarnClusterClient |
Tue, 02 Jan, 15:14 |
aljoscha |
[GitHub] flink issue #5211: [FLINK-8326] [checkpoints] CheckpointCoordinatorTest#test... |
Tue, 02 Jan, 15:14 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function |
Tue, 02 Jan, 15:15 |
Aljoscha Krettek (JIRA) |
[jira] [Closed] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function |
Tue, 02 Jan, 15:15 |
GJL |
[GitHub] flink issue #5219: [FLINK-8332] [flip6] Move savepoint dispose into ClusterC... |
Tue, 02 Jan, 15:16 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8332) Move dispose savepoint into ClusterClient |
Tue, 02 Jan, 15:17 |
tony810430 |
[GitHub] flink pull request #5211: [FLINK-8326] [checkpoints] CheckpointCoordinatorTe... |
Tue, 02 Jan, 15:17 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8326) CheckpointCoordinatorTest#testRestoreLatestCheckpointedStateScaleOut() didn't use the correct parameter to trigger test function |
Tue, 02 Jan, 15:18 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8322) support getting number of existing timers in TimerService |
Tue, 02 Jan, 15:19 |
GJL |
[GitHub] flink pull request #5223: [FLINK-8317][flip6] Implement Triggering of Savepo... |
Tue, 02 Jan, 15:26 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8317) Enable Triggering of Savepoints via RestfulGateway |
Tue, 02 Jan, 15:27 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8318) Conflict jackson library with ElasticSearch connector |
Tue, 02 Jan, 15:28 |
xccui |
[GitHub] flink pull request #5192: [FLINK-8257] [conf] Unify the value checks for set... |
Tue, 02 Jan, 15:28 |
xccui |
[GitHub] flink issue #5192: [FLINK-8257] [conf] Unify the value checks for setParalle... |
Tue, 02 Jan, 15:28 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8257) Unify the value checks for setParallelism() |
Tue, 02 Jan, 15:29 |
Aljoscha Krettek (JIRA) |
[jira] [Comment Edited] (FLINK-8318) Conflict jackson library with ElasticSearch connector |
Tue, 02 Jan, 15:29 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8257) Unify the value checks for setParallelism() |
Tue, 02 Jan, 15:29 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8315) Use AWSCredentialsProvider to get AWS credentials |
Tue, 02 Jan, 15:30 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8314) Add support for Kinesis Firehose |
Tue, 02 Jan, 15:31 |
GJL |
[GitHub] flink pull request #5219: [FLINK-8332] [flip6] Move savepoint dispose into C... |
Tue, 02 Jan, 15:33 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8332) Move dispose savepoint into ClusterClient |
Tue, 02 Jan, 15:34 |
GJL |
[GitHub] flink pull request #5219: [FLINK-8332] [flip6] Move savepoint dispose into C... |
Tue, 02 Jan, 15:35 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8332) Move dispose savepoint into ClusterClient |
Tue, 02 Jan, 15:36 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8305) Docker port mapping doesn't work for JobManager RPC port on Official Flink image |
Tue, 02 Jan, 15:50 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8284) Custom metrics not being exposed for Prometheus |
Tue, 02 Jan, 16:00 |
Aljoscha Krettek (JIRA) |
[jira] [Commented] (FLINK-8282) Transformation with TwoInputStreamOperator fails |
Tue, 02 Jan, 16:10 |
Aljoscha Krettek (JIRA) |
[jira] [Reopened] (FLINK-8272) 1.4 & Scala: Exception when querying the state |
Tue, 02 Jan, 16:13 |
Aljoscha Krettek (JIRA) |
[jira] [Closed] (FLINK-8272) 1.4 & Scala: Exception when querying the state |
Tue, 02 Jan, 16:14 |
Dan Bress (JIRA) |
[jira] [Commented] (FLINK-6206) As an Engineer, I want task state transition log to be warn/error for FAILURE scenarios |
Tue, 02 Jan, 16:20 |
jaredstehler |
[GitHub] flink issue #5208: [FLINK-8265] [Mesos] Missing jackson dependency for flink... |
Tue, 02 Jan, 16:35 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8265) Missing jackson dependency for flink-mesos |
Tue, 02 Jan, 16:36 |
Bhaskar Divya (JIRA) |
[jira] [Commented] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer |
Tue, 02 Jan, 16:37 |
Bhaskar Divya (JIRA) |
[jira] [Comment Edited] (FLINK-8334) Elasticsearch Connector throwing java.lang.ClassNotFoundException: org.jboss.netty.channel.socket.nio.SocketSendBufferPool$GatheringSendBuffer |
Tue, 02 Jan, 16:38 |
Nico Kruber (JIRA) |
[jira] [Created] (FLINK-8350) replace "taskmanager.tmp.dirs" with "env.io.tmp.dirs" for all components |
Tue, 02 Jan, 17:17 |
NicoK |
[GitHub] flink issue #5176: [FLINK-8279][blob] fall back to TaskManager temp director... |
Tue, 02 Jan, 18:12 |
ASF GitHub Bot (JIRA) |
[jira] [Commented] (FLINK-8279) Use Mesos/YARN temp directories as fallback for BlobServer/Cache temp directories |
Tue, 02 Jan, 18:13 |
Thomas Wozniakowski (JIRA) |
[jira] [Commented] (FLINK-8305) Docker port mapping doesn't work for JobManager RPC port on Official Flink image |
Tue, 02 Jan, 18:19 |